当前位置： 维易PHP培训学院 > PHP学习 > 内容正文

php实现与python进行socket通信的方法示例PHP编程：

作者：VEPHP   时间 2017-09-08

《php实现与python进行socket通信的方法示例PHP编程：》要点：
本文介绍了php实现与python进行socket通信的方法示例PHP编程：，希望对您有用。如果有疑问，可以联系我们。

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

设计目的PHP实例

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

index.htmlPHP实例

  1. <html>
  2. <head>
  3.   <title>test</title>
  4.   <script>
  5.   g_xmlHttpReq = new XMLHttpRequest();
  6.   function onReplyCallback()
  7.   {
  8.     if(g_xmlHttpReq.readyState==4 && g_xmlHttpReq.status==200)
  9.     {
  10.       alert(g_xmlHttpReq.responseText);
  11.     }
  12.   }
  13.   function on_stop_service()
  14.   {
  15.     g_xmlHttpReq.open("GET","./service/main.php?cmd=1",true);
  16.     g_xmlHttpReq.onreadystatechange=onReplyCallback;
  17.     g_xmlHttpReq.send(null);
  18.   }
  19.   </script>
  20. </head>
  21. <body>
  22. <button onclick="on_stop_service()">关闭服务</button>
  23. </body>
  24. </html>

service / main.phpPHP实例

  1. <?php
  2. require_once('mysocket.php');
  3. $con = Connector::getInstance();
  4. $req = "aaaaaaa";
  5. $con->sendMsg($req);
  6. $ret = $con->getMsg();
  7. echo $ret;
  8. ?>

service / mysocket.phpPHP实例

  1. <?php
  2. class Connector
  3. {
  4.   public static $instance=null;
  5.   public $conn;
  6.   private function __construct()
  7.   {
  8.       set_time_limit(0);
  9.       $ip = '192.168.238.1';
  10.       $port = 8888;
  11.       if(($this->conn = socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) < 0)
  12.       {
  13.         echo "socket_create() 失败的原因是:".socket_strerror($this->conn)."\n";
  14.       }
  15.       $result = socket_connect($this->conn, $ip, $port);
  16.       if ($result < 0) {
  17.         echo "socket_connect() failed.\nReason: ($result) " . socket_strerror($result) . "\n";
  18.       }else {
  19.         echo "连接OK\n";
  20.       }
  21.   }
  22.   public static function getInstance()
  23.   {
  24.     if(is_null(self::$instance))
  25.     {
  26.       self::$instance = new Connector;
  27.     }
  28.     return self::$instance;
  29.   }
  30.   public function sendMsg($msg)
  31.   {
  32.     socket_write($this->conn,$msg);
  33.   }
  34.   public function getMsg()
  35.   {
  36.     $clients = array($this->conn);
  37.     while(true)
  38.     {
  39.       $read = $clients;
  40.       $wrSet = NULL;
  41.       $errSet = NULL;
  42.       if(socket_select($read, $wrSet,$errSet, 3) < 1)
  43.       {
  44.         continue;
  45.       }
  46.       foreach($read as $read_sock)
  47.       {
  48.         $data = @socket_read($read_sock,1024,PHP_BINARY_READ);
  49.         socket_close($this->conn);
  50.         return $data;
  51.       }
  52.     }
  53.   }
  54. }
  55. ?>

multiServer.pyPHP实例

  1. import threading
  2. import socket
  3. import time
  4. encoding = 'utf-8'
  5. BUFSIZE = 1024
  6. # a read thread, read data from remote
  7. class Reader(threading.Thread):
  8.   def __init__(self, client):
  9.     threading.Thread.__init__(self)
  10.     self.client = client
  11.   def run(self):
  12.     #while True:
  13.     data = self.client.recv(BUFSIZE)
  14.     if(data):
  15.        string = bytes.decode(data, encoding)
  16.        print "from client::",string,""
  17.        time.sleep(10)
  18.        self.client.send("return frome server::" + string)
  19.     print "close:", self.client.getpeername()
  20.   def readline(self):
  21.     rec = self.inputs.readline()
  22.     if rec:
  23.       string = bytes.decode(rec, encoding)
  24.       if len(string)>2:
  25.         string = string[0:-2]
  26.       else:
  27.         string = ' '
  28.     else:
  29.       string = False
  30.     return string
  31. # a listen thread, listen remote connect
  32. # when a remote machine request to connect, it will create a read thread to handle
  33. class Listener(threading.Thread):
  34.   def __init__(self, port):
  35.     threading.Thread.__init__(self)
  36.     self.port = port
  37.     self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  38.     self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
  39.     self.sock.bind(("0.0.0.0", port))
  40.     self.sock.listen(0)
  41.   def run(self):
  42.     print "listener started"
  43.     while True:
  44.       client, cltadd = self.sock.accept()
  45.       print "accept a connect..."
  46.       Reader(client).start()
  47.       cltadd = cltadd
  48.       print "accept a connect(new reader..)"
  49. lst = Listener(8888)  # create a listen thread
  50. lst.start() # then start
  51. # Now, you can use telnet to test it, the command is "telnet 127.0.0.1 9011"
  52. # You also can use web broswer to test, input the address of "http://127.0.0.1:9011" and press Enter button
  53. # Enjoy it....

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

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

转载请注明本页网址：
http://www.vephp.com/jiaocheng/200.html


    标签：  




同类教程排行


特辑教程