wowza,H264通过RTMP发布到Wowza 疯狂代码！

只是一个测试
时间戳的感觉有问题毕竟在RTMP里只是一个24位的整型，如果超过了怎么办呢？？

// demo.cpp : 定义控制台应用程序的入口点。 // #include "stdafx.h" #include <librtmp/rtmp_sys.h> #include <librtmp/log.h> #include <librtmp/amf.h> // starts sockets int InitSockets() { #ifdef WIN32 WORD version; WSADATA wsaData; version = MAKEWORD(1, 1); return (WSAStartup(version, &wsaData) == 0); #else return TRUE; #endif } inline void CleanupSockets() { #ifdef WIN32 WSACleanup(); #endif } #define HEX2BIN(a) (((a)&0x40)?((a)&0xf)+9:((a)&0xf)) int hex2bin(char *str, char **hex) { char *ptr; int i, l = strlen(str); if (l & 1) return 0; *hex = (char *)malloc(l/2); ptr = *hex; if (!ptr) return 0; for (i=0; i<l; i+=2) *ptr++ = (HEX2BIN(str[i]) << 4) | HEX2BIN(str[i+1]); return l/2; } int main(int argc, _TCHAR* argv[]) { RTMP_LogPrintf("InitSockets!\n"); if (!InitSockets()) return -1; RTMP_debuglevel = RTMP_LOGINFO; RTMP *r; //char uri[]="rtmp://192.199.15.223/oflaDemo/mp4:test"; //rtsp://127.0.0.1:1935/live/test char uri[]="rtmp://127.0.0.1/live/test"; r= RTMP_Alloc(); RTMP_Init(r); RTMP_SetupURL(r, (char*)uri); RTMP_EnableWrite(r); RTMP_Connect(r, NULL); RTMP_ConnectStream(r,0); FILE *yuv=fopen("c:\\video-qcif.yuv","rb"); FILE *dbg=fopen("C:\\video-qcif.h264","wb"); unsigned char szNalBuffer[1024*32]; unsigned char szBodyBuffer[1024*32]; x264_nal_t	*p264Nal; int i264Nal; x264_param_t * p264Param; x264_picture_t * p264Pic; x264_t *p264Handle; p264Param = new x264_param_t(); p264Pic = new x264_picture_t(); memset(p264Pic,0,sizeof(x264_picture_t)); x264_param_default(p264Param);	//set default param p264Param->i_width	= 176;	//set frame width p264Param->i_height	= 144;	//set frame height /*baseline level 1.1*/ p264Param->b_cabac =0; p264Param->i_bframe =0; p264Param->b_interlaced=0; p264Param->rc.i_rc_method=X264_RC_CQP; p264Param->i_level_idc=10; //	p264Param->rc.i_qp_constant=22; if((p264Handle = x264_encoder_open(p264Param)) == NULL) { fprintf( stderr, "x264_encoder_open failed\n" ); return -2; } bs_t bs={0}; //fwrite(szNalBuffer,sizeof(char),bs.p-bs.p_start,dbg); x264_picture_alloc(p264Pic, X264_CSP_I420, p264Param->i_width, p264Param->i_height); p264Pic->i_type = X264_TYPE_AUTO; x264_picture_t pic_out; RTMPPacket packet={0}; memset(&packet,0,sizeof(RTMPPacket)); packet.m_nChannel = 0x04;	/* source channel (invoke) */ packet.m_headerType = RTMP_PACKET_SIZE_LARGE; packet.m_packetType = 0x09;	/* INVOKE */ packet.m_nTimeStamp = 0; packet.m_nInfoField2 = r->m_stream_id; packet.m_hasAbsTimestamp = 0; packet.m_body =(char *) szBodyBuffer; szBodyBuffer[ 0]=0x17; szBodyBuffer[ 1]=0x00; szBodyBuffer[ 2]=0x00; szBodyBuffer[ 3]=0x00; szBodyBuffer[ 4]=0x00; szBodyBuffer[ 5]=0x01; szBodyBuffer[ 6]=0x42; szBodyBuffer[ 7]=0xC0; szBodyBuffer[ 8]=0x0D; szBodyBuffer[ 9]=0x03; szBodyBuffer[10]=0x01; unsigned char * szTmp=szBodyBuffer+11; short slen=0; bs_init(&bs,szNalBuffer,16);//初始话bsW x264_sps_write(&bs, p264Handle->sps);//读取编码器的SPS slen=bs.p-bs.p_start+1;//spslen（short） slen=htons(slen); memcpy(szTmp,&slen,sizeof(short)); szTmp+=sizeof(short); *szTmp=0x68; szTmp+=1; memcpy(szTmp,bs.p_start,bs.p-bs.p_start); szTmp+=bs.p-bs.p_start; bs_init(&bs,szNalBuffer,16);//初始话bs x264_pps_write(&bs, p264Handle->pps);//读取编码器的PPS slen=bs.p-bs.p_start+1;//spslen（short） slen=htons(slen); memcpy(szTmp,&slen,sizeof(short)); szTmp+=sizeof(short); *szTmp=0x67; szTmp+=1; memcpy(szTmp,bs.p_start,bs.p-bs.p_start); szTmp+=bs.p-bs.p_start; packet.m_nBodySize=szTmp-szBodyBuffer; RTMP_SendPacket(r,&packet,0); szBodyBuffer[ 1]=0x01; //packet.m_nTimeStamp=0xFFFFFF; while(dbg) { packet.m_nTimeStamp+=50; szBodyBuffer[ 0]=0x17; szBodyBuffer[ 1]=0x01; szBodyBuffer[ 2]=0x00; szBodyBuffer[ 3]=0x00; szBodyBuffer[ 4]=0x00; unsigned char * szTmp=szBodyBuffer+5; //for(int j=0;j<=5;j++) //{ int nCount; nCount=fread(p264Pic->img.plane[0],1,176*144,yuv); if (nCount<176*144) { fseek(yuv,SEEK_SET,0); continue; } nCount=fread(p264Pic->img.plane[1],1,176*144/4,yuv); if (nCount<176*144/4) { fseek(yuv,SEEK_SET,0); continue; } nCount=fread(p264Pic->img.plane[2],1,176*144/4,yuv); if (nCount<176*144/4) { fseek(yuv,SEEK_SET,0); continue; } if( x264_encoder_encode( p264Handle, &p264Nal, &i264Nal, p264Pic ,&pic_out) < 0 ) { fprintf( stderr, "x264_encoder_encode failed\n" ); } for( int i = 0; i < i264Nal; i++ ) { int i_size; int i_data; i_data = 1024*32; if( ( i_size = x264_nal_encode( szNalBuffer, &i_data, 1, &p264Nal[i] ) ) > 0 ) { if (i==0&&szNalBuffer[4]!=0x67) { szBodyBuffer[ 0]=0x27; } else { szBodyBuffer[ 0]=0x17; } if ((szNalBuffer[4]&0x60)==0) { continue; } //unsigned long *len=(unsigned long *)szNalBuffer; int nlen=htonl(i_size-4); memcpy(szTmp,szNalBuffer,i_size); memcpy(szTmp,&nlen,sizeof(unsigned long)); szTmp+=i_size; //fwrite(szNalBuffer,sizeof(char),i_size,dbg); //fflush(dbg); fprintf( stderr, "Info x264_nal_encode[%d] Type:%x size: %d\n",i,szNalBuffer[4], i_size); } else if( i_size < 0 ) { fprintf( stderr,"need to increase buffer size (size=%d)\n", -i_size ); } } Sleep(50); //if (szBodyBuffer[ 0]==0x17) break; //} packet.m_nBodySize=szTmp-szBodyBuffer; RTMP_SendPacket(r,&packet,0); } return 0; }

wowza,H264通过RTMP发布到Wowza

延伸阅读

最新评论

发表评论

赞助商广告

随机更新

热门标注

最近更新

最新标注