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

用户2323866

修改于 2021-07-05 10:19:08

5800

修改于 2021-07-05 10:19:08

文章被收录于专栏：技术派

本文实例讲述了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 onclick="on_stop_service()">关闭服务</button> </body> </html>

service / main.php

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

service / mysocket.php

<?php class 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 "连接OKn"; } } public static function getInstance() { if(is_null(self::$instance))/【本文中一些MYSQL版本可能是以前的，MYSQL建议使用5.7以上的版本】/ { 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 threading import socket import time encoding = 'utf-8' BUFSIZE = 1024

a read thread, read data from remote

class 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::" + strin/【当下浏览的服务器和开发工具是哪些】/g) 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 handle

class 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 thread lst.start() # then start