init
This commit is contained in:
cbcao
commit
ca0a7963b4
|
|
@ -0,0 +1,4 @@
|
||||||
|
#! /bin/sh
|
||||||
|
gcc simplest_ffmpeg_mem_player.cpp -g -o simplest_ffmpeg_mem_player.out -lstdc++ \
|
||||||
|
-I /usr/local/include -L /usr/local/lib -lSDLmain -lSDL -lavformat -lavcodec -lavutil -lswscale
|
||||||
|
|
||||||
|
|
@ -0,0 +1,227 @@
|
||||||
|
/**
|
||||||
|
* 本程序实现对内存中数据的读写并播放
|
||||||
|
* 2016-11-03
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include <stdio.h>
|
||||||
|
|
||||||
|
#define __STDC_CONSTANT_MACROS
|
||||||
|
|
||||||
|
#ifdef _WIN32
|
||||||
|
//Windows
|
||||||
|
extern "C"
|
||||||
|
{
|
||||||
|
#include "libavcodec/avcodec.h"
|
||||||
|
#include "libavformat/avformat.h"
|
||||||
|
#include "libswscale/swscale.h"
|
||||||
|
#include "SDL/SDL.h"
|
||||||
|
};
|
||||||
|
#else
|
||||||
|
//Linux...
|
||||||
|
#ifdef __cplusplus
|
||||||
|
extern "C"
|
||||||
|
{
|
||||||
|
#endif
|
||||||
|
#include <libavcodec/avcodec.h>
|
||||||
|
#include <libavformat/avformat.h>
|
||||||
|
#include <libswscale/swscale.h>
|
||||||
|
#include <SDL/SDL.h>
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <errno.h>
|
||||||
|
#include <sys/socket.h>
|
||||||
|
#include <resolv.h>
|
||||||
|
#include <stdlib.h>
|
||||||
|
#include <netinet/in.h>
|
||||||
|
#include <arpa/inet.h>
|
||||||
|
#include <unistd.h>
|
||||||
|
#ifdef __cplusplus
|
||||||
|
};
|
||||||
|
#endif
|
||||||
|
#endif
|
||||||
|
#define MAXBUF 1024
|
||||||
|
//Output YUV420P
|
||||||
|
#define OUTPUT_YUV420P 0
|
||||||
|
//FILE *fp_open=NULL;
|
||||||
|
int sockfd;
|
||||||
|
|
||||||
|
//Callback
|
||||||
|
int read_buffer(void *opaque, uint8_t *buf, int buf_size){
|
||||||
|
/* 接收对方发过来的文件*/
|
||||||
|
int true_size;
|
||||||
|
if (true_size=recv(sockfd,buf,buf_size,0)){
|
||||||
|
return true_size;
|
||||||
|
}else{
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
int main(int argc, char* argv[])
|
||||||
|
{
|
||||||
|
//socket
|
||||||
|
struct sockaddr_in6 dest; // IPv6
|
||||||
|
|
||||||
|
if (argc != 3) {
|
||||||
|
printf
|
||||||
|
("参数格式错误！正确用法如下：\n\t\t%s IP地址 端口\n\t比如:\t%s 127.0.0.1 80\n此程序用来从某个 IP 地址的服务器某个端口接收最多 MAXBUF 个字节的消息",
|
||||||
|
argv[0], argv[0]);
|
||||||
|
exit(0);
|
||||||
|
}
|
||||||
|
if ((sockfd = socket(AF_INET6, SOCK_STREAM, 0)) < 0) { // IPv6
|
||||||
|
perror("Socket");
|
||||||
|
exit(errno);
|
||||||
|
}
|
||||||
|
printf("socket created\n");
|
||||||
|
|
||||||
|
/* 初始化服务器端（对方）的地址和端口信息 */
|
||||||
|
bzero(&dest, sizeof(dest));
|
||||||
|
dest.sin6_family = AF_INET6; // IPv6
|
||||||
|
dest.sin6_port = htons(atoi(argv[2])); // IPv6
|
||||||
|
if ( inet_pton(AF_INET6, argv[1], &dest.sin6_addr) < 0 ) { // IPv6
|
||||||
|
perror(argv[1]);
|
||||||
|
exit(errno);
|
||||||
|
}
|
||||||
|
printf("address created\n");
|
||||||
|
|
||||||
|
/* 连接服务器 */
|
||||||
|
if (connect(sockfd, (struct sockaddr *) &dest, sizeof(dest)) != 0) {
|
||||||
|
perror("Connect ");
|
||||||
|
exit(errno);
|
||||||
|
}
|
||||||
|
printf("server connected\n");
|
||||||
|
AVFormatContext *pFormatCtx;
|
||||||
|
int i, videoindex;
|
||||||
|
AVCodecContext *pCodecCtx;
|
||||||
|
AVCodec *pCodec;
|
||||||
|
//char filepath[]="1.mp4";
|
||||||
|
|
||||||
|
av_register_all();
|
||||||
|
avformat_network_init();
|
||||||
|
pFormatCtx = avformat_alloc_context();
|
||||||
|
|
||||||
|
//fp_open=fopen(filepath,"rb+");
|
||||||
|
//Init AVIOContext
|
||||||
|
unsigned char *aviobuffer=(unsigned char *)av_malloc(32768);
|
||||||
|
AVIOContext *avio =avio_alloc_context(aviobuffer, 32768,0,NULL,read_buffer,NULL,NULL);
|
||||||
|
pFormatCtx->pb=avio;
|
||||||
|
|
||||||
|
if(avformat_open_input(&pFormatCtx,NULL,NULL,NULL)!=0){
|
||||||
|
printf("Couldn't open input stream.\n");
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
if(avformat_find_stream_info(pFormatCtx,NULL)<0){
|
||||||
|
printf("Couldn't find stream information.\n");
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
videoindex=-1;
|
||||||
|
for(i=0; i<pFormatCtx->nb_streams; i++)
|
||||||
|
if(pFormatCtx->streams[i]->codec->codec_type==AVMEDIA_TYPE_VIDEO){
|
||||||
|
videoindex=i;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
if(videoindex==-1){
|
||||||
|
printf("Didn't find a video stream.\n");
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
pCodecCtx=pFormatCtx->streams[videoindex]->codec;
|
||||||
|
pCodec=avcodec_find_decoder(pCodecCtx->codec_id);
|
||||||
|
if(pCodec==NULL){
|
||||||
|
printf("Codec not found.\n");
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
if(avcodec_open2(pCodecCtx, pCodec,NULL)<0){
|
||||||
|
printf("Could not open codec.\n");
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
AVFrame *pFrame,*pFrameYUV;
|
||||||
|
pFrame=av_frame_alloc();
|
||||||
|
pFrameYUV=av_frame_alloc();
|
||||||
|
//uint8_t *out_buffer=(uint8_t *)av_malloc(avpicture_get_size(AV_PIX_FMT_YUV420P, pCodecCtx->width, pCodecCtx->height));
|
||||||
|
//avpicture_fill((AVPicture *)pFrameYUV, out_buffer, AV_PIX_FMT_YUV420P, pCodecCtx->width, pCodecCtx->height);
|
||||||
|
//SDL----------------------------
|
||||||
|
if(SDL_Init(SDL_INIT_VIDEO | SDL_INIT_AUDIO | SDL_INIT_TIMER)) {
|
||||||
|
printf( "Could not initialize SDL - %s\n", SDL_GetError());
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
int screen_w=0,screen_h=0;
|
||||||
|
SDL_Surface *screen;
|
||||||
|
screen_w = pCodecCtx->width;
|
||||||
|
screen_h = pCodecCtx->height;
|
||||||
|
screen = SDL_SetVideoMode(screen_w, screen_h, 0,0);
|
||||||
|
|
||||||
|
if(!screen) {
|
||||||
|
printf("SDL: could not set video mode - exiting:%s\n",SDL_GetError());
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
SDL_Overlay *bmp;
|
||||||
|
bmp = SDL_CreateYUVOverlay(pCodecCtx->width, pCodecCtx->height,SDL_YV12_OVERLAY, screen);
|
||||||
|
SDL_Rect rect;
|
||||||
|
rect.x = 0;
|
||||||
|
rect.y = 0;
|
||||||
|
rect.w = screen_w;
|
||||||
|
rect.h = screen_h;
|
||||||
|
//SDL End------------------------
|
||||||
|
int ret, got_picture;
|
||||||
|
|
||||||
|
AVPacket *packet=(AVPacket *)av_malloc(sizeof(AVPacket));
|
||||||
|
|
||||||
|
#if OUTPUT_YUV420P
|
||||||
|
FILE *fp_yuv=fopen("output.yuv","wb+");
|
||||||
|
#endif
|
||||||
|
SDL_WM_SetCaption("Simplest FFmpeg Mem Player",NULL);
|
||||||
|
|
||||||
|
struct SwsContext *img_convert_ctx;
|
||||||
|
img_convert_ctx = sws_getContext(pCodecCtx->width, pCodecCtx->height, pCodecCtx->pix_fmt, pCodecCtx->width, pCodecCtx->height, AV_PIX_FMT_YUV420P, SWS_BICUBIC, NULL, NULL, NULL);
|
||||||
|
//------------------------------
|
||||||
|
while(av_read_frame(pFormatCtx, packet)>=0){
|
||||||
|
if(packet->stream_index==videoindex){
|
||||||
|
ret = avcodec_decode_video2(pCodecCtx, pFrame, &got_picture, packet);
|
||||||
|
if(ret < 0){
|
||||||
|
printf("Decode Error.\n");
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
if(got_picture){
|
||||||
|
SDL_LockYUVOverlay(bmp);
|
||||||
|
pFrameYUV->data[0]=bmp->pixels[0];
|
||||||
|
pFrameYUV->data[1]=bmp->pixels[2];
|
||||||
|
pFrameYUV->data[2]=bmp->pixels[1];
|
||||||
|
pFrameYUV->linesize[0]=bmp->pitches[0];
|
||||||
|
pFrameYUV->linesize[1]=bmp->pitches[2];
|
||||||
|
pFrameYUV->linesize[2]=bmp->pitches[1];
|
||||||
|
sws_scale(img_convert_ctx, (const uint8_t* const*)pFrame->data, pFrame->linesize, 0, pCodecCtx->height, pFrameYUV->data, pFrameYUV->linesize);
|
||||||
|
#if OUTPUT_YUV420P
|
||||||
|
int y_size=pCodecCtx->width*pCodecCtx->height;
|
||||||
|
fwrite(pFrameYUV->data[0],1,y_size,fp_yuv); //Y
|
||||||
|
fwrite(pFrameYUV->data[1],1,y_size/4,fp_yuv); //U
|
||||||
|
fwrite(pFrameYUV->data[2],1,y_size/4,fp_yuv); //V
|
||||||
|
#endif
|
||||||
|
SDL_UnlockYUVOverlay(bmp);
|
||||||
|
|
||||||
|
SDL_DisplayYUVOverlay(bmp, &rect);
|
||||||
|
//Delay 40ms
|
||||||
|
SDL_Delay(40);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
av_free_packet(packet);
|
||||||
|
}
|
||||||
|
sws_freeContext(img_convert_ctx);
|
||||||
|
|
||||||
|
#if OUTPUT_YUV420P
|
||||||
|
fclose(fp_yuv);
|
||||||
|
#endif
|
||||||
|
|
||||||
|
//fclose(fp_open);
|
||||||
|
|
||||||
|
SDL_Quit();
|
||||||
|
|
||||||
|
//av_free(out_buffer);
|
||||||
|
av_free(pFrameYUV);
|
||||||
|
avcodec_close(pCodecCtx);
|
||||||
|
avformat_close_input(&pFormatCtx);
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
Binary file not shown.
Binary file not shown.
|
|
@ -0,0 +1,85 @@
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <errno.h>
|
||||||
|
#include <sys/socket.h>
|
||||||
|
#include <resolv.h>
|
||||||
|
#include <stdlib.h>
|
||||||
|
#include <netinet/in.h>
|
||||||
|
#include <arpa/inet.h>
|
||||||
|
#include <unistd.h>
|
||||||
|
#define MAXBUF 1024
|
||||||
|
|
||||||
|
|
||||||
|
int main(int argc, char **argv)
|
||||||
|
{
|
||||||
|
int sockfd, len;
|
||||||
|
/* struct sockaddr_in dest; */ // IPv4
|
||||||
|
struct sockaddr_in6 dest; // IPv6
|
||||||
|
char buffer[MAXBUF + 1];
|
||||||
|
FILE *stream;
|
||||||
|
|
||||||
|
if (argc != 3) {
|
||||||
|
printf
|
||||||
|
("参数格式错误！正确用法如下：\n\t\t%s IP地址 端口\n\t比如:\t%s 127.0.0.1 80\n此程序用来从某个 IP 地址的服务器某个端口接收最多 MAXBUF 个字节的消息",
|
||||||
|
argv[0], argv[0]);
|
||||||
|
exit(0);
|
||||||
|
}
|
||||||
|
/* 创建一个 socket 用于 tcp 通信 */
|
||||||
|
/* if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { */ // IPv4
|
||||||
|
if ((sockfd = socket(AF_INET6, SOCK_STREAM, 0)) < 0) { // IPv6
|
||||||
|
perror("Socket");
|
||||||
|
exit(errno);
|
||||||
|
}
|
||||||
|
printf("socket created\n");
|
||||||
|
|
||||||
|
/* 初始化服务器端（对方）的地址和端口信息 */
|
||||||
|
bzero(&dest, sizeof(dest));
|
||||||
|
/* dest.sin_family = AF_INET; */ // IPv4
|
||||||
|
dest.sin6_family = AF_INET6; // IPv6
|
||||||
|
/* dest.sin_port = htons(atoi(argv[2])); */ // IPv4
|
||||||
|
dest.sin6_port = htons(atoi(argv[2])); // IPv6
|
||||||
|
/* if (inet_aton(argv[1], (struct in_addr *) &dest.sin_addr.s_addr) == 0) { */ // IPv4
|
||||||
|
if ( inet_pton(AF_INET6, argv[1], &dest.sin6_addr) < 0 ) { // IPv6
|
||||||
|
perror(argv[1]);
|
||||||
|
exit(errno);
|
||||||
|
}
|
||||||
|
printf("address created\n");
|
||||||
|
|
||||||
|
/* 连接服务器 */
|
||||||
|
if (connect(sockfd, (struct sockaddr *) &dest, sizeof(dest)) != 0) {
|
||||||
|
perror("Connect ");
|
||||||
|
exit(errno);
|
||||||
|
}
|
||||||
|
printf("server connected\n");
|
||||||
|
|
||||||
|
/* 接收对方发过来的文件*/
|
||||||
|
bzero(buffer, MAXBUF);
|
||||||
|
FILE * fp = fopen("2.mp4","wb");
|
||||||
|
if(NULL == fp )
|
||||||
|
{
|
||||||
|
printf("File:\t%s Can Not Open To Write\n", "2.mp4");
|
||||||
|
exit(1);
|
||||||
|
}
|
||||||
|
int length=0;
|
||||||
|
while (length=recv(sockfd,buffer,MAXBUF,0))
|
||||||
|
{
|
||||||
|
if(length < 0)
|
||||||
|
{
|
||||||
|
printf("Recieve Data From Server Failed!\n");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
int write_length = fwrite(buffer,sizeof(char),length,fp);
|
||||||
|
if (write_length<length)
|
||||||
|
{
|
||||||
|
printf("File:\t%s Write Failed\n", "2.mp4");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
bzero(buffer,MAXBUF);
|
||||||
|
|
||||||
|
}
|
||||||
|
printf("Receive file finished\n");
|
||||||
|
fclose(fp);
|
||||||
|
/* 关闭连接 */
|
||||||
|
close(sockfd);
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,79 @@
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <errno.h>
|
||||||
|
#include <sys/socket.h>
|
||||||
|
#include <resolv.h>
|
||||||
|
#include <stdlib.h>
|
||||||
|
#include <netinet/in.h>
|
||||||
|
#include <arpa/inet.h>
|
||||||
|
#include <unistd.h>
|
||||||
|
#define MAXBUF 1024
|
||||||
|
int main(int argc, char **argv)
|
||||||
|
{
|
||||||
|
int sockfd, len;
|
||||||
|
/* struct sockaddr_in dest; */ // IPv4
|
||||||
|
struct sockaddr_in6 dest; // IPv6
|
||||||
|
char buffer[MAXBUF + 1];
|
||||||
|
|
||||||
|
if (argc != 3) {
|
||||||
|
printf
|
||||||
|
("参数格式错误！正确用法如下：/n/t/t%s IP地址 端口/n/t比如:/t%s 127.0.0.1 80/n此程序用来从某个 IP 地址的服务器某个端口接收最多 MAXBUF 个字节的消息",
|
||||||
|
argv[0], argv[0]);
|
||||||
|
exit(0);
|
||||||
|
}
|
||||||
|
/* 创建一个 socket 用于 tcp 通信 */
|
||||||
|
/* if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { */ // IPv4
|
||||||
|
if ((sockfd = socket(AF_INET6, SOCK_STREAM, 0)) < 0) { // IPv6
|
||||||
|
perror("Socket");
|
||||||
|
exit(errno);
|
||||||
|
}
|
||||||
|
printf("socket created/n");
|
||||||
|
|
||||||
|
/* 初始化服务器端（对方）的地址和端口信息 */
|
||||||
|
bzero(&dest, sizeof(dest));
|
||||||
|
/* dest.sin_family = AF_INET; */ // IPv4
|
||||||
|
dest.sin6_family = AF_INET6; // IPv6
|
||||||
|
/* dest.sin_port = htons(atoi(argv[2])); */ // IPv4
|
||||||
|
dest.sin6_port = htons(atoi(argv[2])); // IPv6
|
||||||
|
/* if (inet_aton(argv[1], (struct in_addr *) &dest.sin_addr.s_addr) == 0) { */ // IPv4
|
||||||
|
if ( inet_pton(AF_INET6, argv[1], &dest.sin6_addr) < 0 ) { // IPv6
|
||||||
|
perror(argv[1]);
|
||||||
|
exit(errno);
|
||||||
|
}
|
||||||
|
printf("address created/n");
|
||||||
|
|
||||||
|
/* 连接服务器 */
|
||||||
|
if (connect(sockfd, (struct sockaddr *) &dest, sizeof(dest)) != 0) {
|
||||||
|
perror("Connect ");
|
||||||
|
exit(errno);
|
||||||
|
}
|
||||||
|
printf("server connected/n");
|
||||||
|
|
||||||
|
/* 接收对方发过来的消息，最多接收 MAXBUF 个字节 */
|
||||||
|
bzero(buffer, MAXBUF + 1);
|
||||||
|
/* 接收服务器来的消息 */
|
||||||
|
len = recv(sockfd, buffer, MAXBUF, 0);
|
||||||
|
if (len > 0)
|
||||||
|
printf("接收消息成功:'%s'，共%d个字节的数据/n",
|
||||||
|
buffer, len);
|
||||||
|
else
|
||||||
|
printf
|
||||||
|
("消息接收失败！错误代码是%d，错误信息是'%s'/n",
|
||||||
|
errno, strerror(errno));
|
||||||
|
|
||||||
|
bzero(buffer, MAXBUF + 1);
|
||||||
|
strcpy(buffer, "这是客户端发给服务器端的消息/n");
|
||||||
|
/* 发消息给服务器 */
|
||||||
|
len = send(sockfd, buffer, strlen(buffer), 0);
|
||||||
|
if (len < 0)
|
||||||
|
printf
|
||||||
|
("消息'%s'发送失败！错误代码是%d，错误信息是'%s'/n",
|
||||||
|
buffer, errno, strerror(errno));
|
||||||
|
else
|
||||||
|
printf("消息'%s'发送成功，共发送了%d个字节！/n",
|
||||||
|
buffer, len);
|
||||||
|
|
||||||
|
/* 关闭连接 */
|
||||||
|
close(sockfd);
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
Binary file not shown.
Binary file not shown.
|
|
@ -0,0 +1,107 @@
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <stdlib.h>
|
||||||
|
#include <errno.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <sys/types.h>
|
||||||
|
#include <netinet/in.h>
|
||||||
|
#include <sys/socket.h>
|
||||||
|
#include <sys/wait.h>
|
||||||
|
#include <unistd.h>
|
||||||
|
#include <arpa/inet.h>
|
||||||
|
#define MAXBUF 1024
|
||||||
|
int main(int argc, char **argv)
|
||||||
|
{
|
||||||
|
int sockfd, new_fd;
|
||||||
|
socklen_t len;
|
||||||
|
FILE *stream;
|
||||||
|
|
||||||
|
/* struct sockaddr_in my_addr, their_addr; */ // IPv4
|
||||||
|
struct sockaddr_in6 my_addr, their_addr; // IPv6 ,my_addr服务器地址
|
||||||
|
|
||||||
|
unsigned int myport, lisnum;
|
||||||
|
char buf[MAXBUF + 1];
|
||||||
|
//argv[1]服务器端口号
|
||||||
|
if (argv[1])
|
||||||
|
myport = atoi(argv[1]);
|
||||||
|
else
|
||||||
|
myport = 7838;
|
||||||
|
|
||||||
|
if (argv[2])
|
||||||
|
lisnum = atoi(argv[2]);
|
||||||
|
else
|
||||||
|
lisnum = 2;
|
||||||
|
|
||||||
|
/* if ((sockfd = socket(PF_INET, SOCK_STREAM, 0)) == -1) { */ // IPv4
|
||||||
|
if ((sockfd = socket(PF_INET6, SOCK_STREAM, 0)) == -1) { // IPv6
|
||||||
|
perror("socket");
|
||||||
|
exit(1);
|
||||||
|
} else
|
||||||
|
printf("socket created\n");
|
||||||
|
|
||||||
|
bzero(&my_addr, sizeof(my_addr));
|
||||||
|
/* my_addr.sin_family = PF_INET; */ // IPv4
|
||||||
|
my_addr.sin6_family = PF_INET6; // IPv6
|
||||||
|
/* my_addr.sin_port = htons(myport); */ // IPv4
|
||||||
|
my_addr.sin6_port = htons(myport); // IPv6
|
||||||
|
|
||||||
|
if (argv[3])
|
||||||
|
/* my_addr.sin_addr.s_addr = inet_addr(argv[3]); */ // IPv4
|
||||||
|
inet_pton(AF_INET6, argv[3], &my_addr.sin6_addr); // IPv6
|
||||||
|
else
|
||||||
|
/* my_addr.sin_addr.s_addr = INADDR_ANY; */ // IPv4
|
||||||
|
my_addr.sin6_addr = in6addr_any; // IPv6
|
||||||
|
|
||||||
|
/* if (bind(sockfd, (struct sockaddr *) &my_addr, sizeof(struct sockaddr)) */ // IPv4
|
||||||
|
if (bind(sockfd, (struct sockaddr *) &my_addr, sizeof(struct sockaddr_in6))== -1) {
|
||||||
|
perror("bind");
|
||||||
|
exit(1);
|
||||||
|
} else
|
||||||
|
printf("binded\n");
|
||||||
|
|
||||||
|
if (listen(sockfd, lisnum) == -1) {
|
||||||
|
perror("listen");
|
||||||
|
exit(1);
|
||||||
|
} else
|
||||||
|
printf("begin listen\n");
|
||||||
|
|
||||||
|
while (1) {
|
||||||
|
len = sizeof(struct sockaddr);
|
||||||
|
if ((new_fd = accept(sockfd, (struct sockaddr *) &their_addr, &len)) == -1) {
|
||||||
|
perror("accept");
|
||||||
|
exit(errno);
|
||||||
|
} else
|
||||||
|
printf("server: got connection from %s, port %d, socket %d\n",
|
||||||
|
/* inet_ntoa(their_addr.sin_addr), */ // IPv4
|
||||||
|
inet_ntop(AF_INET6, &their_addr.sin6_addr, buf, sizeof(buf)), // IPv6
|
||||||
|
/* ntohs(their_addr.sin_port), new_fd); */ // IPv4
|
||||||
|
their_addr.sin6_port, new_fd); // IPv6
|
||||||
|
|
||||||
|
|
||||||
|
//打开文件
|
||||||
|
if ((stream = fopen("doctor_strange.flv", "rb")) == NULL) {
|
||||||
|
printf("The file doctor_strange.flv not opend!");
|
||||||
|
exit(1);
|
||||||
|
} else
|
||||||
|
printf("open file:doctor_strange.flv");
|
||||||
|
/* 开始处理每个新连接上的数据收发 */
|
||||||
|
bzero(buf, MAXBUF);
|
||||||
|
|
||||||
|
int lengsize = 0;
|
||||||
|
while ((lengsize = fread(buf, 1, 1024, stream)) > 0) {
|
||||||
|
if (send(new_fd, buf, lengsize, 0) < 0) {
|
||||||
|
printf("send file failed!");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
bzero(buf, MAXBUF);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (fclose(stream)) {
|
||||||
|
printf("File data not closed\n");
|
||||||
|
exit(1);
|
||||||
|
}
|
||||||
|
close(new_fd);
|
||||||
|
}
|
||||||
|
close(sockfd);
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
@ -0,0 +1,107 @@
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <stdlib.h>
|
||||||
|
#include <errno.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <sys/types.h>
|
||||||
|
#include <netinet/in.h>
|
||||||
|
#include <sys/socket.h>
|
||||||
|
#include <sys/wait.h>
|
||||||
|
#include <unistd.h>
|
||||||
|
#include <arpa/inet.h>
|
||||||
|
#define MAXBUF 1024
|
||||||
|
int main(int argc, char **argv)
|
||||||
|
{
|
||||||
|
int sockfd, new_fd;
|
||||||
|
socklen_t len;
|
||||||
|
FILE *stream;
|
||||||
|
|
||||||
|
/* struct sockaddr_in my_addr, their_addr; */ // IPv4
|
||||||
|
struct sockaddr_in6 my_addr, their_addr; // IPv6 ,my_addr服务器地址
|
||||||
|
|
||||||
|
unsigned int myport, lisnum;
|
||||||
|
char buf[MAXBUF + 1];
|
||||||
|
//argv[1]服务器端口号
|
||||||
|
if (argv[1])
|
||||||
|
myport = atoi(argv[1]);
|
||||||
|
else
|
||||||
|
myport = 7838;
|
||||||
|
|
||||||
|
if (argv[2])
|
||||||
|
lisnum = atoi(argv[2]);
|
||||||
|
else
|
||||||
|
lisnum = 2;
|
||||||
|
|
||||||
|
/* if ((sockfd = socket(PF_INET, SOCK_STREAM, 0)) == -1) { */ // IPv4
|
||||||
|
if ((sockfd = socket(PF_INET6, SOCK_STREAM, 0)) == -1) { // IPv6
|
||||||
|
perror("socket");
|
||||||
|
exit(1);
|
||||||
|
} else
|
||||||
|
printf("socket created\n");
|
||||||
|
|
||||||
|
bzero(&my_addr, sizeof(my_addr));
|
||||||
|
/* my_addr.sin_family = PF_INET; */ // IPv4
|
||||||
|
my_addr.sin6_family = PF_INET6; // IPv6
|
||||||
|
/* my_addr.sin_port = htons(myport); */ // IPv4
|
||||||
|
my_addr.sin6_port = htons(myport); // IPv6
|
||||||
|
|
||||||
|
if (argv[3])
|
||||||
|
/* my_addr.sin_addr.s_addr = inet_addr(argv[3]); */ // IPv4
|
||||||
|
inet_pton(AF_INET6, argv[3], &my_addr.sin6_addr); // IPv6
|
||||||
|
else
|
||||||
|
/* my_addr.sin_addr.s_addr = INADDR_ANY; */ // IPv4
|
||||||
|
my_addr.sin6_addr = in6addr_any; // IPv6
|
||||||
|
|
||||||
|
/* if (bind(sockfd, (struct sockaddr *) &my_addr, sizeof(struct sockaddr)) */ // IPv4
|
||||||
|
if (bind(sockfd, (struct sockaddr *) &my_addr, sizeof(struct sockaddr_in6))== -1) {
|
||||||
|
perror("bind");
|
||||||
|
exit(1);
|
||||||
|
} else
|
||||||
|
printf("binded\n");
|
||||||
|
|
||||||
|
if (listen(sockfd, lisnum) == -1) {
|
||||||
|
perror("listen");
|
||||||
|
exit(1);
|
||||||
|
} else
|
||||||
|
printf("begin listen\n");
|
||||||
|
|
||||||
|
while (1) {
|
||||||
|
len = sizeof(struct sockaddr);
|
||||||
|
if ((new_fd = accept(sockfd, (struct sockaddr *) &their_addr, &len)) == -1) {
|
||||||
|
perror("accept");
|
||||||
|
exit(errno);
|
||||||
|
} else
|
||||||
|
printf("server: got connection from %s, port %d, socket %d\n",
|
||||||
|
/* inet_ntoa(their_addr.sin_addr), */ // IPv4
|
||||||
|
inet_ntop(AF_INET6, &their_addr.sin6_addr, buf, sizeof(buf)), // IPv6
|
||||||
|
/* ntohs(their_addr.sin_port), new_fd); */ // IPv4
|
||||||
|
their_addr.sin6_port, new_fd); // IPv6
|
||||||
|
|
||||||
|
|
||||||
|
//打开文件
|
||||||
|
if ((stream = fopen("cuc60anniversary_start.mkv", "rb")) == NULL) {
|
||||||
|
printf("The file cuc60anniversary_start.mkv not opend!");
|
||||||
|
exit(1);
|
||||||
|
} else
|
||||||
|
printf("open file:cuc60anniversary_start.mkv");
|
||||||
|
/* 开始处理每个新连接上的数据收发 */
|
||||||
|
bzero(buf, MAXBUF);
|
||||||
|
|
||||||
|
int lengsize = 0;
|
||||||
|
while ((lengsize = fread(buf, 1, 1024, stream)) > 0) {
|
||||||
|
if (send(new_fd, buf, lengsize, 0) < 0) {
|
||||||
|
printf("send file failed!");
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
bzero(buf, MAXBUF);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (fclose(stream)) {
|
||||||
|
printf("File data not closed\n");
|
||||||
|
exit(1);
|
||||||
|
}
|
||||||
|
close(new_fd);
|
||||||
|
}
|
||||||
|
close(sockfd);
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
Loading…
Reference in New Issue