全网整合营销服务商

电脑端+手机端+微信端=数据同步管理

免费咨询热线:400-708-3566

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

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


# php  # python  # socket  # 通信  # Python socket实现的简单通信功能示例  # Python基于socket模块实现UDP通信功能示例  # Python网络编程使用select实现socket全双工异步通信功能示例  # Python socket网络编程TCP/IP服务器与客户端通信  # 利用Python中SocketServer 实现客户端与服务器间非阻塞通信  # 结合Python的SimpleHTTPServer源码来解析socket通信  # python实现简单socket通信的方法  # Python通过websocket与js客户端通信示例分析  # python socket通信编程实现文件上传代码实例  # 程序设计  # 相关内容  # 感兴趣  # 数据结构  # 给大家  # 更多关于  # 所述  # 面向对象  # 操作技巧  # 编程技巧  # 讲述了  # sendMsg  # ret  # aaaaaaa  # getInstance  # req  # static  # instance  # public  # getMsg 


相关文章: 如何用低价快速搭建高质量网站?  公众号网站制作网页,微信公众号怎么制作?  如何设置并定期更换建站之星安全管理员密码?  济南专业网站制作公司,济南信息工程学校怎么样?  建站之星多图banner生成与模板自定义指南  建站一年半SEO优化实战指南:核心词挖掘与长尾流量提升策略  如何做网站制作流程,*游戏网站怎么搭建?  如何选择长沙网站建站模板?H5响应式与品牌定制哪个更优?  网站制作与设计教程,如何制作一个企业网站,建设网站的基本步骤有哪些?  Android自定义listview布局实现上拉加载下拉刷新功能  单页制作网站有哪些,朋友给我发了一个单页网站,我应该怎么修改才能把他变成自己的呢,请求高手指点迷津?  如何挑选最适合建站的高性能VPS主机?  常州自助建站费用包含哪些项目?  建站之星×万网:智能建站系统+自助建站平台一键生成  手机怎么制作网站教程步骤,手机怎么做自己的网页链接?  做企业网站制作流程,企业网站制作基本流程有哪些?  如何选择网络建站服务器?高效建站必看指南  如何打造高效商业网站?建站目的决定转化率  建站为何优先选择香港服务器?  相册网站制作软件,图片上的网址怎么复制?  建站之星代理如何获取技术支持?  广州商城建站系统开发成本与周期如何控制?  北京网站制作费用多少,建立一个公司网站的费用.有哪些部分,分别要多少钱?  怎么制作网站设计模板图片,有电商商品详情页面的免费模板素材网站推荐吗?  如何高效生成建站之星成品网站源码?  佛山网站制作系统,佛山企业变更地址网上办理步骤?  c# await 一个已经完成的Task会发生什么  香港服务器如何优化才能显著提升网站加载速度?  电商网站制作公司有哪些,1688网是什么意思?  香港代理服务器配置指南:高匿IP选择、跨境加速与SEO优化技巧  C++中引用和指针有什么区别?(代码说明)  美食网站链接制作教程视频,哪个教做美食的网站比较专业点?  零服务器AI建站解决方案:快速部署与云端平台低成本实践  免费制作小说封面的网站有哪些,怎么接网站批量的封面单?  如何用y主机助手快速搭建网站?  Swift中循环语句中的转移语句 break 和 continue  网站按钮制作软件,如何实现网页中按钮的自动点击?  湖州网站制作公司有哪些,浙江中蓝新能源公司官网?  建站之星价格显示格式升级,你的预算足够吗?  建站OpenVZ教程与优化策略:配置指南与性能提升  整蛊网站制作软件,手机不停的收到各种网站的验证码短信,是手机病毒还是人为恶搞?有这种手机病毒吗?  如何快速配置高效服务器建站软件?  建站VPS能否同时实现高效与安全翻墙?  定制建站方案优化指南:企业官网开发与建站费用解析  公司网站的制作公司,企业网站制作基本流程有哪些?  定制建站是什么?如何实现个性化需求?  在线制作视频的网站有哪些,电脑如何制作视频短片?  XML的“混合内容”是什么 怎么用DTD或XSD定义  如何在阿里云高效完成企业建站全流程?  小自动建站系统:AI智能生成+拖拽模板,多端适配一键搭建 

您的项目需求

*请认真填写需求信息,我们会在24小时内与您取得联系。