当前位置:Gxlcms > PHP教程 > 如何实现php与python进行socket通信的方法示例

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

时间:2021-07-01 10:21:17 帮助过:8人阅读

这篇文章主要介绍了php实现与python进行socket通信的方法,结合实例形式分析了php使用自定义类发送socket请求数据及Python接收socket数据并处理请求等相关操作技巧,需要的朋友可以参考下

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

设计目的

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

index.html


  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.php


  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.php


  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.py


  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与python进行socket通信的方法示例的详细内容,更多请关注Gxl网其它相关文章!

人气教程排行