php socket通信机制实例说明与代码

 更新时间:2016年11月25日 16:28  点击:1777

一,socket是什么

      什么是socket 所谓socket通常也称作"套接字",用于描述ip地址和端口,是一个通信链的句柄。应用程序通常通过"套接字"向网络发出请求或者应答网络请求。说白了就是一种通信机制。它类似于银行,电信啊这些部分的电话客服部门。你打电话的时候,那边会分配置一个人回答你的问题,客服部门就相当于socket的服务器端了,你这边呢就相当于客户端了,在和你通话结束前,如果有人在想找和你通话的那个说话,是不可能的,因为你在和他通信,当然客服部门的电话交换机也不会重复分配。
下面我将举例子来说明一下,socket是怎么工作的。如果你是基于应用层开发的人员并不一定要理解原理,但是能知道那是更好了。网上有关于socket的php api。下下来用就行了。

二,socket服务器server.php
<?php
// 建立server端socket
$tcp = getprotobyname("tcp");
$socket = socket_create(af_inet, sock_stream, $tcp);
socket_bind($socket, '127.0.0.1', 10008);       //绑定要监听的端口
socket_listen($socket);       //监听端口

//初始化一个数据,和客户端通信
$buffer = "connect";
while (true) {
    // 接受一个socket连接
    $connection = socket_accept($socket);
    if(!$connection){
        echo "connect fail";
    }else{
            echo  "socket connected ";
            // 向客户端传递一个信息数据
            if ($buffer != "") {
                echo "send data to client ";
                socket_write($connection, $buffer . " ");
                echo  "wrote to socket ";
            } else {
                echo  "no data in the buffer " ;
            }
            // 从客户端取得信息
            while ($data = @socket_read($connection, 1024, php_normal_read)) {
                    printf("buffer: " . $data . " ");
                    //取得信息给客户端一个反馈
                    socket_write($connection, "information received ");
            }
    }

    socket_close($connection);
    //关闭 socket
    printf("closed the socket ");
}
?>

三,socket客户端client.php
<?php
// 建立客户端的socet连接
$socket = socket_create(af_inet, sock_stream, sol_tcp);
$connection = socket_connect($socket, '127.0.0.1', 10008);    //连接服务器端socket

while ($buffer = @socket_read($socket, 1024, php_normal_read)) {
    //服务端告诉客户端,自己的状态
    if (preg_match("/not connect/",$buffer)) {
        echo "don`t connect ";
        break;
    } else {
        //服务器传来信息
        echo "buffer data: " . $buffer . " ";

        echo "writing to socket ";
        // 将客户的信息写到通道中,传给服务器端
        if (!socket_write($socket, "some data ")) {
            echo "write failed ";
        }
        //服务器端收到信息后,给于的回应信息
        while ($buffer = socket_read($socket, 1024, php_normal_read)) {
                echo "sent to server: some data response from server was:" . $buffer . " ";
        }

    }
}

?>

四,通信机制的一个图片(不考虑等待时间结束自动关闭socket)

 

简单说明一下,在说明前我要说一下,为什么要用php命令来执行服务器和客户端,客户端你用fsockopen,这样就在流览器上访问了,不至少于会连接超时。为什么会这样呢,因为你创建一个socket时,它会不断的去监听客户有没有要来连接。

socket通信的建立要二个socket通道,一个是服务器端创建的,一个是客户端创建的。
1号线,服务器创建一个socket通道,并将信息放到缓存,等待客户端连接
2号线,客户端创建一个socket通道,并连接服务器端,取得服务器端的信息进行通信,将要传的信息送入通道
3号线,服务器端从客户端取得信息,并告诉客户端,信息我已经收到了。将要传的信息送入通道
4号线,客户端从服务器端取得确认信息
到此一个通信就完全建立了,数据传输完毕后,服务器端会断开socket通信,具体操作如下


1,运行socket服务器端


[root@blackghost zhangy]# /usr/local/php/bin/php -a /home/zhangy/www/test2/server.php
interactive mode enabled
这一点做了那些工作呢
a,监听了一个10008端口
[zhangy@blackghost ~]$ netstat -an |grep listen |grep 10008
tcp        0      0 127.0.0.1:10008         0.0.0.0:*               listen
[zhangy@blackghost ~]$
b,将信息送到缓存里面$buffer = "connect";看上面的代码

2,运行socket客户端

[root@blackghost zhangy]# /usr/local/php/bin/php -a /home/zhangy/www/test2/client.php
interactive mode enabled

buffer data: connect

writing to socket
sent to server: some data
response from server was:information received

3,回到服务器端

[root@blackghost zhangy]# /usr/local/php/bin/php -a /home/zhangy/www/test2/server.php
interactive mode enabled

socket connected
send data to client
wrote to socket
buffer: some data

closed the socket

  

 代码如下 复制代码

function bigendian2int($byte_word, $signed = false) { 
 
  $int_value = 0; 
 
  $byte_wordlen = strlen($byte_word); 
 
  for ($i = 0; $i < $byte_wordlen; $i++) 
 
  { 
 
  $int_value += ord($byte_word{$i}) * pow(256, ($byte_wordlen - 1 - $i)); 
 
  } 
 
  if ($signed) 
 
  { 
 
  $sign_mask_bit = 0x80 << (8 * ($byte_wordlen - 1)); 
 
  if ($int_value & $sign_mask_bit) 
 
  { 
 
  $int_value = 0 - ($int_value & ($sign_mask_bit - 1)); 
 
  } 
 
  } 
 
  return $int_value; 
 
  } 
 
  function gettime($name){ 
 
  if(!file_exists($name)){ 
 
  return; 
 
  } 
 
  $flv_data_length=filesize($name); 
 
  $fp = @fopen($name, 'rb'); 
 
  $flv_header = fread($fp, 5); 
 
  fseek($fp, 5, seek_set); 
 
  $frame_size_data_length =bigendian2int(fread($fp, 4)); 
 
  $flv_header_frame_length = 9; 
 
  if ($frame_size_data_length > $flv_header_frame_length) { 
 
  fseek($fp, $frame_size_data_length - $flv_header_frame_length, seek_cur); 
 
  } 
 
  $duration = 0; 
 
  while ((ftell($fp) + 1) < $flv_data_length) { 
 
  $this_tag_header = fread($fp, 16); 
 
  $data_length = bigendian2int(substr($this_tag_header, 5, 3)); 
 
  $timestamp = bigendian2int(substr($this_tag_header, 8, 3)); 
 
  $next_offset = ftell($fp) - 1 + $data_length; 
 
  if ($timestamp > $duration) { 
 
  $duration = $timestamp; 
 
  } 
 
  fseek($fp, $next_offset, seek_set); 
 
  } 
 
  fclose($fp); 
 
  return $duration; 
 
  } 
 
  function fn($time){ 
 
  $num = $time; 
 
  $sec = intval($num / 1000); 
 
  $h = intval($sec / 3600); 

  $m = intval(($sec % 3600) / 60); 
 
  $s = intval(($sec % 60 )); 
 
  $tm = $h . ':' . $m . ':' . $s ; 
 
  return $tm; 
 
  }   
  echo gettime("27729.flv");//显示数字时间如236722   
  echo fn(236722); //显示时间格式0:03:56 

 代码如下 复制代码
$conn=mysql教程_connect("localhost","root","123456");
$pagesize=4;//设定每一页显示的记录数
mysql_select_db("ly",$conn);
$rs=mysql_query("select count(*) from lyb",$conn);//取得记录总数$rs,计算总页数用
$myrow = mysql_fetch_array($rs);
$numrows=$myrow[0];
$pages=intval($numrows/$pagesize);//计算总页数
if ($numrows%$pagesize)
$pages++;
//设置页数
if (isset($_get['page'])){
$page=intval($_get['page']);}
else{
//设置为第一页
$page=1;
}
//计算记录偏移量
$offset=$pagesize*($page - 1);
//读取指定记录数
$rs=mysql_query("select * from lyb order by id desc limit $offset,$pagesize",$conn);
if ($myrow = mysql_fetch_array($rs))
{
$i=0;
?>
  <table border="0" width="80%">
  </tr>
  <?php
do {
$i++;
    ?>
   <td width="10%"><?=$myrow["nichen"]?></td>
  
  <?php
}
while ($myrow = mysql_fetch_array($rs));
echo "</tr></table>";

方法一


$txt=$_get['url'];
echo referfile($txt,'http://www.111cn.net/');

function referfile($url,$refer='') {
$opt=array('http'=>array('header'=>"referer:$refer"));
$context=stream_context_create($opt);
header("location:".$url);
return file_get_contents($url,false,$context);
}


<?php
$host = "pakey.net"; //你要访问的域名
$target = "/test.asp教程"; //你要访问的页面地址
$referer = "http//uuwar.com/"; //伪造来路页面
$fp = fsockopen($host, 80, $errno, $errstr, 30);
if(!$fp){
echo "$errstr($errno)<br /> ";
}else{
$out = "
get $target http/1.1
host: $host
referer: $referer
connection: close ";

fwrite($fp, $out);
while(!feof($fp)){
echo fgets($fp, 1024);
}
fclose($fp);
}
?>

其它方法
<?
$url=str_replace('/file.php/','',$_server["request_uri"]);//得出需要转换的网址。这里我就偷懒,不做安全检测了,需要的自己加上去
$downfile=str_replace(" ","%20",$url);//替换空格之类,可以根据实际情况进行替换
$downfile=str_replace("http://","",$downfile);//去掉http://
$urlarr=explode("/",$downfile);//以"/"分解出域名
$domain=$urlarr[0];//域名
$getfile=str_replace($urlarr[0],'',$downfile);//得出header中的get部分
$content = @fsockopen("$domain", 80, $errno, $errstr, 12);//连接目标主机
if (!$content){//链接不上就提示错误
die("对不起,无法连接上 $domain 。");
}
fputs($content, "get $getfile http/1.0rn");
fputs($content, "host: $domainrn");
fputs($content, "referer: $domainrn");//伪造部分
fputs($content, "user-agent: mozilla/4.0 (compatible; msie 6.0; windows nt 5.1)rnrn");
while (!feof($content)) {
$tp.=fgets($content, 128);
if (strstr($tp,"200 ok")){ //这里要说明一下。header的第一行一般是请求文件的状态。具体请参照http 1.1状态代码及其含义 hi.baidu.com/110911/blog/item/21f20d2475af812ed50742c5.html这里是正常的文件请求状态,只需直接转向就可以。其他状态的继续执行程序
header("location:$url");
die();
}
}
//302 转向,大部分的防盗链系统都是先判断referfer,对了的话再转向真实的地址。下面就是获取真实的地址。
$arr=explode("n",$tp);
$arr1=explode("location: ",$tp);//分解出location后面的真时地址
$arr2=explode("n",$arr1[1]);
header('content-type:application/force-download');//强制下载
header("location:".$arr2[0]);//转向目标地址
die();
?>

 

  //--------------------------------------------------
  function getindextext($okstr,$ilen=-1)
  {
    if($okstr=="") return "";
    $ws = explode(" ",$okstr);
    $okstr = "";
    $wks = "";
    foreach($ws as $w)
    {
      $w = trim($w);
      //排除小于2的字符
      if(strlen($w)<2) continue;
      //排除数字或日期
      if(!ereg("[^0-9:-]",$w)) continue;
      if(strlen($w)==2&&ord($w[0])>0x80) continue;
      if(isset($wks[$w])) $wks[$w]++;
      else $wks[$w] = 1;
    }
    if(is_array($wks))
    {
      arsort($wks);
      if($ilen==-1)
      { foreach($wks as $w=>$v) $okstr .= $w." "; }
      else
      {
        foreach($wks as $w=>$v){
          if((strlen($okstr)+strlen($w)+1)<$ilen) $okstr .= $w." ";
          else break;
        }
      }
    }
    return trim($okstr);
  }?>

[!--infotagslink--]

相关文章

  • 不打开网页直接查看网站的源代码

      有一种方法,可以不打开网站而直接查看到这个网站的源代码..   这样可以有效地防止误入恶意网站...   在浏览器地址栏输入:   view-source:http://...2016-09-20
  • php 调用goolge地图代码

    <?php require('path.inc.php'); header('content-Type: text/html; charset=utf-8'); $borough_id = intval($_GET['id']); if(!$borough_id){ echo ' ...2016-11-25
  • JS基于Mootools实现的个性菜单效果代码

    本文实例讲述了JS基于Mootools实现的个性菜单效果代码。分享给大家供大家参考,具体如下:这里演示基于Mootools做的带动画的垂直型菜单,是一个初学者写的,用来学习Mootools的使用有帮助,下载时请注意要将外部引用的mootools...2015-10-23
  • JS+CSS实现分类动态选择及移动功能效果代码

    本文实例讲述了JS+CSS实现分类动态选择及移动功能效果代码。分享给大家供大家参考,具体如下:这是一个类似选项卡功能的选择插件,与普通的TAb区别是加入了动画效果,多用于商品类网站,用作商品分类功能,不过其它网站也可以用,...2015-10-21
  • JS实现自定义简单网页软键盘效果代码

    本文实例讲述了JS实现自定义简单网页软键盘效果。分享给大家供大家参考,具体如下:这是一款自定义的简单点的网页软键盘,没有使用任何控件,仅是为了练习JavaScript编写水平,安全性方面没有过多考虑,有顾虑的可以不用,目的是学...2015-11-08
  • php 取除连续空格与换行代码

    php 取除连续空格与换行代码,这些我们都用到str_replace与正则函数 第一种: $content=str_replace("n","",$content); echo $content; 第二种: $content=preg_replac...2016-11-25
  • php简单用户登陆程序代码

    php简单用户登陆程序代码 这些教程很对初学者来讲是很有用的哦,这款就下面这一点点代码了哦。 <center> <p>&nbsp;</p> <p>&nbsp;</p> <form name="form1...2016-11-25
  • PHP实现清除wordpress里恶意代码

    公司一些wordpress网站由于下载的插件存在恶意代码,导致整个服务器所有网站PHP文件都存在恶意代码,就写了个简单的脚本清除。恶意代码示例...2015-10-23
  • js识别uc浏览器的代码

    其实挺简单的就是if(navigator.userAgent.indexOf('UCBrowser') > -1) {alert("uc浏览器");}else{//不是uc浏览器执行的操作}如果想测试某个浏览器的特征可以通过如下方法获取JS获取浏览器信息 浏览器代码名称:navigator...2015-11-08
  • JS实现双击屏幕滚动效果代码

    本文实例讲述了JS实现双击屏幕滚动效果代码。分享给大家供大家参考,具体如下:这里演示双击滚屏效果代码的实现方法,不知道有觉得有用处的没,现在网上还有很多还在用这个特效的呢,代码分享给大家吧。运行效果截图如下:在线演...2015-10-30
  • JS日期加减,日期运算代码

    一、日期减去天数等于第二个日期function cc(dd,dadd){//可以加上错误处理var a = new Date(dd)a = a.valueOf()a = a - dadd * 24 * 60 * 60 * 1000a = new Date(a)alert(a.getFullYear() + "年" + (a.getMonth() +...2015-11-08
  • PHP开发微信支付的代码分享

    微信支付,即便交了保证金,你还是处理测试阶段,不能正式发布。必须到你通过程序测试提交订单、发货通知等数据到微信的系统中,才能申请发布。然后,因为在微信中是通过JS方式调用API,必须在微信后台设置支付授权目录,而且要到...2014-05-31
  • PHP常用的小程序代码段

    本文实例讲述了PHP常用的小程序代码段。分享给大家供大家参考,具体如下:1.计算两个时间的相差几天$startdate=strtotime("2009-12-09");$enddate=strtotime("2009-12-05");上面的php时间日期函数strtotime已经把字符串...2015-11-24
  • php怎么用拼音 简单的php中文转拼音的实现代码

    小编分享了一段简单的php中文转拼音的实现代码,代码简单易懂,适合初学php的同学参考学习。 代码如下 复制代码 <?phpfunction Pinyin($_String...2017-07-06
  • c# socket网络编程接收发送数据示例代码

    这篇文章主要介绍了c# socket网络编程,server端接收,client端发送数据,大家参考使用吧...2020-06-25
  • php导出csv格式数据并将数字转换成文本的思路以及代码分享

    php导出csv格式数据实现:先定义一个字符串 存储内容,例如 $exportdata = '规则111,规则222,审222,规222,服2222,规则1,规则2,规则3,匹配字符,设置时间,有效期'."/n";然后对需要保存csv的数组进行foreach循环,例如复制代...2014-06-07
  • ecshop商品无限级分类代码

    ecshop商品无限级分类代码 function cat_options($spec_cat_id, $arr) { static $cat_options = array(); if (isset($cat_options[$spec_cat_id]))...2016-11-25
  • 几种延迟加载JS代码的方法加快网页的访问速度

    本文介绍了如何延迟javascript代码的加载,加快网页的访问速度。 当一个网站有很多js代码要加载,js代码放置的位置在一定程度上将会影像网页的加载速度,为了让我们的网页加载速度更快,本文总结了一下几个注意点...2013-10-13
  • 详解JS WebSocket断开原因和心跳机制

    这篇文章主要介绍了JS WebSocket断开原因和心跳机制,对websocket感兴趣的同学,可以参考下...2021-05-08
  • C#实现Socket通信的解决方法

    这篇文章主要介绍了C#实现Socket通信的解决方法,需要的朋友可以参考下...2020-06-25