{
    分享网正式开通,我们为大家提供免费资源,欢迎大家踊跃投稿!

php实现与python进行socket通信的方法示例

本文实例讲述了php实现与python进行socket通信的方法。分享给大家供大家参考,具体如下:

设计目的

通过前端页面发起请求交给php,php创建socket请求交给Python脚本,然后执行完毕之后,返回给前端。

index.html

<html><head>  <title>test</title>  <script>  g_xmlHttpReq = new XMLHttpRequest();  function onReplyCallback()  {    if(g_xmlHttpReq.readyState==4 && g_xmlHttpReq.status==200)    {      alert(g_xmlHttpReq.responseText);    }  }  function on_stop_service()  {    g_xmlHttpReq.open("GET","./service/main.php?cmd=1",true);    g_xmlHttpReq.onreadystatechange=onReplyCallback;    g_xmlHttpReq.send(null);  }  </script></head><body><button >关闭服务</button></body></html>

service / main.php

<?phprequire_once('mysocket.php');$con = Connector::getInstance();$req = "aaaaaaa";$con->sendMsg($req);$ret = $con->getMsg();echo $ret;?>

service / mysocket.php

<?phpclass Connector{  public static $instance=null;  public $conn;  private function __construct()  {      set_time_limit(0);      $ip = '192.168.238.1';      $port = 8888;      if(($this->conn = socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) < 0)      {        echo "socket_create() 失败的原因是:".socket_strerror($this->conn)."/n";      }      $result = socket_connect($this->conn, $ip, $port);      if ($result < 0) {        echo "socket_connect() failed./nReason: ($result) " . socket_strerror($result) . "/n";      }else {        echo "连接OK/n";      }  }  public static function getInstance()  {    if(is_null(self::$instance))    {      self::$instance = new Connector;    }    return self::$instance;  }  public function sendMsg($msg)  {    socket_write($this->conn,$msg);  }  public function getMsg()  {    $clients = array($this->conn);    while(true)    {      $read = $clients;      $wrSet = NULL;      $errSet = NULL;      if(socket_select($read, $wrSet,$errSet, 3) < 1)      {        continue;      }      foreach($read as $read_sock)      {        $data = @socket_read($read_sock,1024,PHP_BINARY_READ);        socket_close($this->conn);        return $data;      }    }  }}?>

multiServer.py

import threadingimport socketimport timeencoding = 'utf-8'BUFSIZE = 1024# a read thread, read data from remoteclass Reader(threading.Thread):  def __init__(self, client):    threading.Thread.__init__(self)    self.client = client  def run(self):    #while True:    data = self.client.recv(BUFSIZE)    if(data):       string = bytes.decode(data, encoding)       print "from client::",string,""       time.sleep(10)       self.client.send("return frome server::" + string)    print "close:", self.client.getpeername()  def readline(self):    rec = self.inputs.readline()    if rec:      string = bytes.decode(rec, encoding)      if len(string)>2:        string = string[0:-2]      else:        string = ' '    else:      string = False    return string# a listen thread, listen remote connect# when a remote machine request to connect, it will create a read thread to handleclass Listener(threading.Thread):  def __init__(self, port):    threading.Thread.__init__(self)    self.port = port    self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)    self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)    self.sock.bind(("0.0.0.0", port))    self.sock.listen(0)  def run(self):    print "listener started"    while True:      client, cltadd = self.sock.accept()      print "accept a connect..."      Reader(client).start()      cltadd = cltadd      print "accept a connect(new reader..)"lst = Listener(8888)  # create a listen threadlst.start() # then start# Now, you can use telnet to test it, the command is "telnet 127.0.0.1 9011"# You also can use web broswer to test, input the address of "http://127.0.0.1:9011" and press Enter button# Enjoy it....

更多关于PHP相关内容感兴趣的读者可查看本站专题:《php socket用法总结》、《php字符串(string)用法总结》、《PHP数学运算技巧总结》、《php面向对象程序设计入门教程》、《PHP数组(Array)操作技巧大全》、《PHP数据结构与算法教程》、《php程序设计算法总结》及《PHP网络编程技巧总结》

希望本文所述对大家PHP程序设计有所帮助。




米微资源分享网 , 版权所有丨本站资源仅限于学习研究,严禁从事商业或者非法活动!丨本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:php实现与python进行socket通信的方法示例
喜欢 ()分享 (0)