本文共 2976 字，大约阅读时间需要 9 分钟。

## 设计目的

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

## index.html

		关闭服务

   sendMsg($req);$ret = $con->getMsg();echo $ret;?>

## service / mysocket.php

   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;			}		}	}}?>

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

转载地址：http://ijvbi.baihongyu.com/