这篇文章主要介绍了php实现与python进行socket通信的方法,结合实例形式分析了php使用自定义类发送socket请求数据及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 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 "连接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 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::" + 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 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
# 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与python进行socket通信的方法示例的详细内容。