开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > 流媒体/Mpeg4/MP4 > 查看源码
simplesip.pl
资源名称：rtsp-1.0.1.tar.gz　[点击查看]
上传用户：sy_wanhua
上传日期：2013-07-25
资源大小：3048k
文件大小：11k
源码类别：

流媒体/Mpeg4/MP4

开发平台：

C/C++

simplesip.pl：源码内容
  1. #!/usr/bin/perl
  3. # ====================================================================
  4. # The Vovida Software License, Version 1.0 
  5. # 
  6. # Copyright (c) 2000 Vovida Networks, Inc.  All rights reserved.
  7. # 
  8. # Redistribution and use in source and binary forms, with or without
  9. # modification, are permitted provided that the following conditions
  10. # are met:
  11. # 
  12. # 1. Redistributions of source code must retain the above copyright
  13. #    notice, this list of conditions and the following disclaimer.
  14. # 
  15. # 2. Redistributions in binary form must reproduce the above copyright
  16. #    notice, this list of conditions and the following disclaimer in
  17. #    the documentation and/or other materials provided with the
  18. #    distribution.
  19. # 
  20. # 3. The names "VOCAL", "Vovida Open Communication Application Library",
  21. #    and "Vovida Open Communication Application Library (VOCAL)" must
  22. #    not be used to endorse or promote products derived from this
  23. #    software without prior written permission. For written
  24. #    permission, please contact vocal@vovida.org.
  25. # 
  26. # 4. Products derived from this software may not be called "VOCAL", nor
  27. #    may "VOCAL" appear in their name, without prior written
  28. #    permission of Vovida Networks, Inc.
  29. # 
  30. # THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
  31. # WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  32. # OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, TITLE AND
  33. # NON-INFRINGEMENT ARE DISCLAIMED.  IN NO EVENT SHALL VOVIDA
  34. # NETWORKS, INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT DAMAGES
  35. # IN EXCESS OF $1,000, NOR FOR ANY INDIRECT, INCIDENTAL, SPECIAL,
  36. # EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
  37. # PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
  38. # PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
  39. # OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  40. # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
  41. # USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
  42. # DAMAGE.
  43. # 
  44. # ====================================================================
  45. # 
  46. # This software consists of voluntary contributions made by Vovida
  47. # Networks, Inc. and many individuals on behalf of Vovida Networks,
  48. # Inc.  For more information on Vovida Networks, Inc., please see
  49. # <http://www.vovida.org/>.
  51. # $Id: simplesip.pl,v 1.4 2000/08/12 01:25:13 bogawa Exp $
  53. # simple script to manage UDP to TCP for SIP connections
  55. use Test2;
  56. use IO::Socket;
  57. use Socket;
  58. use Data::Dumper;
  60. &mkudpsocket(5060, S1);
  62. $local_addr = "192.168.5.31";
  63. $code_text{"180"} = "Ringing";
  64. $code_text{"200"} = "OK";
  66. sub start_rtp {
  67.     local($rtp) = @_;
  68.     open($rtp, "| ./rtpSimple > rtpsimple.log") 
  69.       || die "can't start rtpSimple: $!";
  71.     # unbuffer the filehandle
  72.     $a = select($rtp);
  73.     $| = 1;
  74.     select($a);
  75. }
  77. $rtp = "RTP";
  79. &start_rtp($rtp);
  81. while(1) {
  82.     $rin = '';
  83.     $max_fh = -1;
  84.     vec($rin, fileno(S1), 1) = 1;
  86. #    print "wheel!n";
  88.     if(select($rin, undef, undef, 10)) {
  89. @bits = split(//, unpack("b*", $rin));
  90. undef($data);
  91. undef($new_data);
  92. # print "inn";
  93. if($bits[fileno(S1)]) {
  94.     $his_address = &handle_udp(S1, $tcp_socket);
  95. }
  96.     } else {
  97. # nothing, so bye!
  98. # &bye_udp(S1);
  99.     }
  100. }
  102. sub bye_udp {
  103.     if(!$last_invite) {
  104. return;
  105.     }
  106.     local($bye) = &generate_bye($last_invite);
  108. #    print "bye:n";
  109. #    print $bye;
  110. #    print "n";
  111.     if(length($bye)) {
  112. &post_data_udp(S1, $bye, $his_address);
  113.     }
  114.     $last_invite = "";
  115. }
  117. sub handle_udp {
  118.     my($udp_socket, $tcp_socket) = @_;
  119.     my($his_address);
  120.     my($data);
  122. #    print "handling udpn";
  124.     $his_address = recv($udp_socket, $data, 60000, 0);
  125.     if($data) {
  126. # print "---------- UDP ----------n";
  127. # print $data;
  128. # print "---------- --- ----------n";
  129. open(JUNK, ">junk.txt");
  130. print JUNK $data;
  131. close(JUNK);
  132.     }
  134.     $data = &filter_udp2tcp($data);
  136.     if(length($data)) {
  137. &post_data_udp(S1, $data, $his_address);
  138.     }
  139.     return $his_address;
  140. }
  143. sub post_data_udp {
  144.     my($socket, $data, $his_address) = @_;
  146.     ($hisport, $hisiaddr) = sockaddr_in($his_address);
  147.     $hishost = inet_ntoa($hisiaddr);
  148. #    print "returns: $hishost:$hisport:n----$datan----n";
  149.     ($sin) = pack_sockaddr_in(5060, $hisiaddr);
  150.     
  151. # defined(send(S1,$return_data,0,$sin)) || die $!;
  152.     defined(send($socket, $data, 0,$sin)) || die "send: $!";
  153.     $them_S2 = pack($sockaddr,PF_INET, 5060, 192.168);
  154. #    print "returns: donen";
  155.     return;
  156. }
  159. sub mkudpsocket {
  160.   local($port, $socket) = @_;
  161.   
  162.   ($name,$aliases,$proto) = getprotobyname('udp');
  163.   socket($socket, PF_INET, SOCK_DGRAM, $proto) || die "socket: $!";
  164.   $paddr = sockaddr_in($port, INADDR_ANY); # 0 means let kernel pick
  165.   bind($socket , $paddr) || die "died with port $port $!";
  166.   
  167. }
  170. sub filter_udp2tcp {
  171.     local($_) = @_;
  173.     if(/^invite/i) {
  174. # $_ = &respond($_, 180, "", "");
  175. # respond w/ 200, natch!
  176. $last_invite = $_;
  177. $hostport = &process_sdp($_);
  178. ($remote_host, $remote_port) = split(/:/, $hostport);
  179. $_ = &respond($_, 200, &make_sdp($local_addr, "3466"), "application/sdp");
  180. print $rtp "n 3466 $remote_host $remote_portn";
  182. #    local($hostip) = "192.168.5.3";
  183. #    local($port) = "3466";
  184.     } else {
  185. if(/^sip/i) {
  187. } elsif(/^ack/i) {
  188.     $_ = "";
  189. #     print RTP "p sample.rawn";
  190. #     print RTP "r record.rawn";
  191.     print $rtp "v p:sample.raw p:beep.raw r:record.rawn";
  192. } elsif(/^bye/i) {
  193.     $_ = &respond($_, 200, "", "");
  194.     $last_invite = "";
  195.     print $rtp "dn";
  196.     system("sleep 1; sox -r 8000 -U -b record.raw record.au &");
  197. } else {
  198.     $_ = &respond($_, 200, "", "");
  199. }
  200.     }
  202. #    print Dumper(&turntohash($_));
  204. #    print $_;
  206.     return $_;
  207. }
  209. sub respond {
  210.     local($old_msg, $code, $content, $content_type) = @_;
  211.     local($msg);
  213.     # take an incoming message, and form1 an outgoing message from it
  214.     $msg = "SIP/2.0 $code $code_text{$code}rn";
  215.     $msg .= &strip_extraneous($old_msg);
  216.     $msg = &add_content($msg, $content, $content_type);
  217. }
  219. sub generate_bye {
  220.     # byes are a special case -- they need a different CSeq, and the
  221.     # From/To may need to be reversed as appropriate
  223.     local($invite_msg) = @_;
  225.     local($bye_msg);
  227.     $bye_msg = &inc_cseq($invite_msg, "BYE");
  229.     local($msg_hash) = &turntohash($bye_msg);
  231.     local($old_from) = $msg_hash->{"from"};
  232.     local($old_to) = $msg_hash->{"to"};
  234.     $bye_msg = "BYE $msg_hash->{MSG_URL} SIP/2.0rn" 
  235.       . &strip_extraneous($bye_msg);
  237. #    print $bye_msg;
  239.     if($old_from =~ /$local_addr[^0-9]/) {
  240.     } else {
  241. $bye_msg = &replace_header($bye_msg, "from", $old_to);
  242. $bye_msg = &replace_header($bye_msg, "to", $old_from);
  243.     }
  245.     print $rtp "dn";
  247.     # do something here
  249.     return $bye_msg;
  250. }
  252. sub replace_header {
  253.     local($msg, $header, $new_contents) = @_;
  255.     @split_msg = split(/r?n/, $msg);
  256.     $linecount = 0;
  257.     local($new_msg) = "";
  258.     $past_headers = 0;
  260.     $header =~ y/A-Z/a-z/;
  262.     foreach(@split_msg) {
  263. if($linecount == 0) {
  264.     $new_msg .= $_ . "rn";
  265. } else {
  266.     if(/^[srn]*$/) {
  267. $past_headers = 1;
  268.     }
  269.     if (!$past_headers) {
  270. ($header_name, $header_body) = split(/:/, $_, 2);
  271. $header_name =~ y/A-Z/a-z/;
  272. if($header_name eq $header) {
  273.     # do something!
  274.     $header_body = $new_contents;
  275. }
  276. $new_msg .= $header_name . ":" . $header_body . "rn" ;
  277.     } else {
  278. # gobble everything else and put it into a thingy
  279. $new_msg .= $_ . "rn";
  280.     }
  281. }
  282. $linecount++;
  283.     }
  284.     return $new_msg;
  285. }
  288. sub turntohash {
  289.     local($msg) = @_;
  290.     local($hash);
  292.     $hash = {};
  294.     @split_msg = split(/r?n/, $msg);
  295.     $linecount = 0;
  296.     $newmsg = "";
  297.     $past_headers = 0;
  299.     $header =~ y/A-Z/a-z/;
  301.     foreach(@split_msg) {
  302. if($linecount == 0) {
  303.     $hash->{"FIRST_LINE"} = $_;
  304.     # figure out if this is a request or a response
  305.     @stuff = split(/s+/);
  306.     if($stuff[0] !~ /^SIP/) {
  307. $stuff[0] =~ y/A-Z/a-z/;
  308. $stuff[2] =~ y/A-Z/a-z/;
  309. $hash->{"MSG_TYPE"} = $stuff[0];
  310. $hash->{"MSG_URL"} = $stuff[1];
  311. $hash->{"SIP_VERSION"} = $stuff[2];
  312.     } else {
  313. $stuff[0] =~ y/A-Z/a-z/;
  314. $stuff[2] =~ y/A-Z/a-z/;
  315. $hash->{"SIP_VERSION"} = $stuff[0];
  316. $hash->{"MSG_TYPE"} = "response";
  317. $hash->{"RESPONSE_CODE"} = $stuff[1];
  318. $hash->{"RESPONSE_TEXT"} = $stuff[2];
  319.     }
  320. } else {
  321.     if(/^[srn]*$/) {
  322. $past_headers = 1;
  323. next;
  324.     }
  325.     if (!$past_headers) {
  326. ($header_name, $header_body) = split(/:/, $_, 2);
  327. $header_name =~ y/A-Z/a-z/;
  328. $hash->{$header_name} = $header_body;
  329.     } else {
  330. # gobble everything else and put it into a thingy
  331. $hash->{"CONTENTS"} .= $_ . "rn";
  332.     }
  333. }
  334. $linecount++;
  335.     }
  336.     return $hash;
  337. }
  340. sub turntomsg {
  341.     local($hash) = @_;
  342.     local($msg);
  344.     if($hash->{"MSG_TYPE"} eq "response") {
  345. # this is a response
  347.     } else {
  350.     }
  351. }
  355. sub inc_cseq {
  356.     local($msg, $type) = @_;
  358.     local($stuff, $num);
  360.     $msg =~ s/cseq:s*(.*)r?n/CSeq: rn/i;
  361.     $stuff = $1;
  362.     $stuff =~ /^([0-9]+)/;
  363.     $num = $1; 
  364.     $num++;
  365.     $msg =~ s/CSeq: rn/CSeq: $num $typern/;
  366.     return $msg;
  367. }
  370. sub process_sdp {
  371.     local($sdp) = @_;
  373.     local($host, $port);
  375.     # chomp out the appropriate stuff
  376.     if(/o=.*IP4s+([0-9.]+)/) {
  377. $host = $1;
  378.     }
  379.     if(/m=.*audios+([0-9]+)/) {
  380. $port = $1;
  381.     }
  382.     return "$host:$port";
  383. }
  387. sub make_sdp {
  388.     local($hostip, $port) = @_;
  389. #    local($hostip) = "192.168.5.3";
  390. #    local($port) = "3466";
  391.     local($sdp_info);
  393.     $sdp_info  = "v=0rn";
  394.     $sdp_info .= "o=- 305743370 305743370 IN IP4 $hostiprn";
  395.     $sdp_info .= "s=VOVIDA Sessionrn";
  396.     $sdp_info .= "c=IN IP4 $hostiprn";
  397.     $sdp_info .= "t=957844468 0rn";
  398.     $sdp_info .= "m=audio $port RTP/AVP 0rn";
  399.     $sdp_info .= "a=rtpmap:0 PCMU/8000rn";
  400.     $sdp_info .= "a=ptime:40rn";
  402.     return $sdp_info;
  403. }
  405. sub add_content {
  406.     local($msg, $content, $content_type) = @_;
  408. #    print "content: n", $content, "n ---------- n";
  410.     if(!$content) {
  411. $msg .= "Content-Length: 0rnrn";
  412.     } else {
  413. $msg .= "Content-Type: $content_typern";
  414. $msg .= "Content-Length: " . length($content) . "rn";
  415. $msg .= "rn";
  416. $msg .= $content;
  417.     }
  418.     return $msg;
  419. }
  422. sub strip_extraneous {
  423.     local($msg) = $_[0];
  424.     # take an incoming message, and form an outgoing message from it
  426.     @split_msg = split(/r?n/, $msg);
  427.     $linecount = 0;
  428.     $newmsg = "";
  429.     $past_headers = 0;
  431.     foreach(@split_msg) {
  432. if($linecount == 0) {
  433.     if(/^SIP/2.0/ || /^INVITE/i || /^BYE/i || /^ACK/i || /^CANCEL/i) {
  434.     # get rid of this
  435.     } else {
  436. $newmsg .= $_ . "rn";
  437.     }
  438. } else {
  439.     if(/^[srn]*$/) {
  440. # print "past headers!nn";
  441. $past_headers = 1;
  442.     } else {
  443. # print "ok:$linecount:$_:n";
  444.     }
  445.     if(!/^content-length:/i 
  446.        && !/^content-type:/i 
  447.        && !($past_headers)) {
  448. # print "got $_n";
  449. $newmsg .= $_ . "rn";
  450.     }
  451. }
  453. $linecount++;
  454.     }
  455.     return $newmsg;
  456. }
  460. __END__