rtsp服务器

  • e5_229891
    了解作者
  • 7.2KB
    文件大小
  • gz
    文件格式
  • 0
    收藏次数
  • VIP专享
    资源类型
  • 0
    下载次数
  • 2022-04-07 05:43
    上传日期
rtsp服务器代码,实现rtsp简单服务器源代码
rtsp服务器.tar.gz
  • 初步成形的rtsp服务器
  • h264.h
    1.5KB
  • rtp_rtsp.c
    20.6KB
  • client_test.c
    1.3KB
内容介绍
// NALDecoder.cpp : Defines the entry point for the console application. // #include <stdio.h> #include <stdlib.h> #include <string.h> #include <memory.h> #include <errno.h> #include <netdb.h> #include <time.h> #include <sys/types.h> #include <netinet/in.h> #include <sys/socket.h> #include <arpa/inet.h rel='nofollow' onclick='return false;'> #include <unistd.h> //close() #include "h264.h" //#define DEST_PORT 8888 typedef struct { int startcodeprefix_len; //! 4 for parameter sets and first slice in picture, 3 for everything else (suggested) unsigned len; //! Length of the NAL unit (Excluding the start code, which does not belong to the NALU) unsigned max_size; //! Nal Unit Buffer size int forbidden_bit; //! should be always FALSE int nal_reference_idc; //! NALU_PRIORITY_xxxx int nal_unit_type; //! NALU_TYPE_xxxx char *buf; //! contains the first byte followed by the EBSP unsigned short lost_packets; //! true, if packet loss is detected } NALU_t; FILE *bits = NULL; //!< the bit stream file static int FindStartCode2 (unsigned char *Buf);//查找开始字符0x000001 static int FindStartCode3 (unsigned char *Buf);//查找开始字符0x00000001 //static bool flag = true; static int info2=0, info3=0; RTP_FIXED_HEADER *rtp_hdr; NALU_HEADER *nalu_hdr; FU_INDICATOR *fu_ind; FU_HEADER *fu_hdr; /** int sock_init(int sockfd,struct sockaddr_in addr,int SERVER_PORT) { sockfd=socket(AF_INET,SOCK_DGRAM,0); if(sockfd<0) { fprintf(stderr,"Socket Error:%s\n",strerror(errno)); exit(1); } printf("sockfd is %d\n",sockfd); bzero(&addr,sizeof(struct sockaddr_in)); addr.sin_family=AF_INET; addr.sin_addr.s_addr=htonl(INADDR_ANY); addr.sin_port=htons(SERVER_PORT); if(bind(sockfd,(struct sockaddr *)&addr,sizeof(struct sockaddr_in))<0) { fprintf(stderr,"Bind Error:%s\n",strerror(errno)); exit(1); } printf("init successfel!!\nport is %dsockfd is %d\n",SERVER_PORT,sockfd); return 0; } */ char* sock_recv(int sockfd,struct sockaddr *addr_client,int *addrlen) { //int *tem_len = &addrlen; socklen_t len; printf("sock_recv sockfd is %d\n",sockfd); char *recv_buffer = malloc (sizeof (char)); //printf("sock_recv sockfd is88888888888888 %d\n",sockfd); int n; n=recvfrom(sockfd,recv_buffer,256,0,addr_client,&len); //printf("recv number is %d\n",n); if(0) { printf("recvfrom error!\n"); exit (1); } if(-1==n) { perror("recv error:"); } else { addrlen=(int *)len; printf("sock recv success!!\n"); /** char IPdotdec[20]; //存放点分十进制IP地址 struct in_addr s = inet_ntop(AF_INET, (void *)&s, IPdotdec, 16); printf("addr_client.data=%s\n",IPdotdec); */ printf("addr_len=%ld\n",addrlen); } return recv_buffer; } //为NALU_t结构体分配内存空间 NALU_t *AllocNALU(int buffersize) { NALU_t *n; if ((n = (NALU_t*)calloc (1, sizeof (NALU_t))) == NULL) { printf("AllocNALU: n"); exit(0); } n->max_size=buffersize; if ((n->buf = (char*)calloc (buffersize, sizeof (char))) == NULL) { free (n); printf ("AllocNALU: n->buf"); exit(0); } return n; } //释放 void FreeNALU(NALU_t *n) { if (n) { if (n->buf) { free(n->buf); n->buf=NULL; } free (n); } } void OpenBitstreamFile (char *fn) { if (NULL == (bits=fopen(fn, "rb"))) { printf("open file error\n"); exit(0); } printf("test264 open successful!\n"); } //这个函数输入为一个NAL结构体,主要功能为得到一个完整的NALU并保存在NALU_t的buf中,获取他的长度,填充F,IDC,TYPE位。 //并且返回两个开始字符之间间隔的字节数,即包含有前缀的NALU的长度 int GetAnnexbNALU (NALU_t *nalu) { int pos = 0; int StartCodeFound, rewind; unsigned char *Buf; if ((Buf = (unsigned char*)calloc (nalu->max_size , sizeof(char))) == NULL) printf ("GetAnnexbNALU: Could not allocate Buf memory\n"); nalu->startcodeprefix_len=3;//初始化码流序列的开始字符为3个字节 if (3 != fread (Buf, 1, 3, bits))//从码流中读3个字节 { free(Buf); return 0; } info2 = FindStartCode2 (Buf);//判断是否为0x000001 if(info2 != 1) { //如果不是,再读一个字节 if(1 != fread(Buf+3, 1, 1, bits))//读一个字节 { free(Buf); return 0; } info3 = FindStartCode3 (Buf);//判断是否为0x00000001 if (info3 != 1)//如果不是,返回-1 { free(Buf); return -1; } else { //如果是0x00000001,得到开始前缀为4个字节 pos = 4; nalu->startcodeprefix_len = 4; } } else { //如果是0x000001,得到开始前缀为3个字节 nalu->startcodeprefix_len = 3; pos = 3; } //查找下一个开始字符的标志位 StartCodeFound = 0; info2 = 0; info3 = 0; while (!StartCodeFound) { if (feof (bits))//判断是否到了文件尾 { nalu->len = (pos-1)-nalu->startcodeprefix_len; memcpy (nalu->buf, &Buf[nalu->startcodeprefix_len], nalu->len); nalu->forbidden_bit = nalu->buf[0] & 0x80; //1 bit nalu->nal_reference_idc = nalu->buf[0] & 0x60; // 2 bit nalu->nal_unit_type = (nalu->buf[0]) & 0x1f;// 5 bit free(Buf); return pos-1; } Buf[pos++] = fgetc (bits);//读一个字节到BUF中 info3 = FindStartCode3(&Buf[pos-4]);//判断是否为0x00000001 if(info3 != 1) info2 = FindStartCode2(&Buf[pos-3]);//判断是否为0x000001 StartCodeFound = (info2 == 1 || info3 == 1); } // Here, we have found another start code (and read length of startcode bytes more than we should // have. Hence, go back in the file rewind = (info3 == 1)? -4 : -3; if (0 != fseek (bits, rewind, SEEK_CUR))//把文件指针指向前一个NALU的末尾 { free(Buf); printf("GetAnnexbNALU: Cannot fseek in the bit stream file"); } // Here the Start code, the complete NALU, and the next start code is in the Buf. // The size of Buf is pos, pos+rewind are the number of bytes excluding the next // start code, and (pos+rewind)-startcodeprefix_len is the size of the NALU excluding the start code // 不管有没有再次读到 头 ,其主要 关心的还是 nalu->len nalu->len = (pos+rewind)-nalu->startcodeprefix_len; memcpy (nalu->buf, &Buf[nalu->startcodeprefix_len], nalu->len);//拷贝一个完整NALU,不拷贝起始前缀0x000001或0x00000001 nalu->forbidden_bit = nalu->buf[0] & 0x80; //1 bit nalu->nal_reference_idc = nalu->buf[0] & 0x60; // 2 bit nalu->nal_unit_type = (nalu->buf[0]) & 0x1f;// 5 bit free(Buf); return (pos+rewind);//返回两个开始字符之间间隔的字节数,即包含有前缀的NALU的长度 } //输出NALU长度和TYPE void dump(NALU_t *n) { if (!n)return; //printf("a new nal:"); printf(" len: %d ", n->len); printf("nal_unit_type: %x\n", n->nal_unit_type); } int rtp_send_file(int sockfd,struct sockaddr *addr) { printf("into the rtp_send_file...\n"); int rtp_number; OpenBitstreamFile("./test.264");//打开264文件,并将文件指针赋给bits,在此修改文件名实现打开别的264文件。 NALU_t *n; char* nalu_payload; char sendbuf[1500]; unsigned short seq_num =0; int bytes=0; float framerate=15; unsigned int timestamp_increse=0,ts_current=0; timestamp_increse=(unsigned int)(90000.0 / framerate); //+0.5); sleep(3); n = AllocNALU(80000000);//为结构体nalu_t及其成员buf分配空间。返回值为指向nalu_t存储空间的指针 sleep(3); printf("before the GetAnnexbNALU\n"); while(!feof(bits)) { GetAnnexbNALU(n);//每执行一次,文件的指针指向本次找到的NALU的末尾,下一个位置即为下个NALU的起始码0x000001 //dump(n);//输出NALU长度和TYPE memset(sendbuf,0,1500);//清空sendbuf;此时会将上次的时间戳清空,因此需要ts_current来保存上次的时间戳值 //rtp固定包头,为12字节,该句将sendbuf[0]的地址赋给rtp_hdr,以后对rtp_hdr的写入操作将直接写入sendbuf。 rtp_hdr =(RTP_FIXED_HEADER*)&sendbuf[0]; //设置RTP HEADER, rtp_hdr->payload = H264; //负载类型
评论
    相关推荐
    • wbe服务器
      可以自己制作登录服务器、不过自己网一定要好。。不然你自己网是2兆的 10个20个登录你服务器。。那样爆了别怪我。。
    • 服务器
      服务器 这是eosdg的服务器
    • ASP服务器
      很迷你但实用的一款ASP服务器
    • 注意服务器
      注意服务器分配 这是值得注意的服务器项目
    • 时间服务器
      此款软件为时间服务器,分为两个客户端--服务器端及客户端。
    • 服务器探针
      服务器探针,检测服务器资源配置,以便对程序编写方便.
    • TCP服务器
      TCP服务器 服务器TCP na labolatorium zInżynieriiOprogramowania
    • AUCE服务器
      AUCE服务器 这是一台在Heroku中运行的服务器,它主要是服务器中的主要服务器。 (但是也许再也没有。) 设置 Heroku应用程序在 您可以尝试 端口是:1234 贡献 欢迎提出请求。 对于重大更改,请先打开一个问题以讨论...
    • 服务器服务器
      C服务器 这是一个小型Websocket服务器,它需要音频块并发送Cerence云请求以进行ASR识别。 它使用库 。
    • Trivia服务器
      Trivia服务器 #此服务器是一个网络滚动项目,它基于新协议创建服务器进行通信! #Ariel Chitiat,Noam Harel,Yoav Cat Levin