ZMQ通过http推送集成

我正在尝试使用php和本地zmq实现推送集成。我已经成功地发送发送我的消息到服务器，但我的问题是我不能使用js Websocket()将消息推送到浏览器。我说WebSocket连接到'ws://127.0.0.1:8080/'失败:WebSocket握手时错误:无效状态行

下面是我的客户端代码:

<?php
 try {
   function send($data) {
      $context = new ZMQContext();
      $push = new ZMQSocket($context, ZMQ::SOCKET_PUSH);
      $push->connect("tcp://localhost:5555");
      $push->send($data);
    }    
    if(isset($_POST["username"])) {
      $envelope = array(
        "from" => "client",
        "to" => "owner",
        "msg" => $_POST["username"]
      );
      send(json_encode($envelope)); # send the data to server
    }
 }
 catch( Exception $e ) {
   echo $e->getMessage();
 }
?>

客户端

这是我的服务器:

$context = new ZMQContext();
$pull = new ZMQSocket($context, ZMQ::SOCKET_PULL);
$pull->bind("tcp://*:5555"); #this will be my pull socket from client
$push = new ZMQSocket($context, ZMQ::SOCKET_PUSH);
$push->bind("tcp://127.0.0.1:8080"); # this will be the push socket to owner
while(true) {
    $data = $pull->recv(); # when I receive the data decode it
    $parse_data = json_decode($parse_data);
    if($parse_data["to"] == "owner") {
        $push->send($parse_data["msg"]); # forward the data to the owner
    }
    printf("Recieve: %s.n", $data);
}

和这里是我的所有者。php我期待的数据是通过Websocket在浏览器发送:

<html>
<head>
    <meta charset="UTF-8">
    <title></title>
</head>
<body>
    <h2>Message</h2>
    <ul id="messagelog">
    </ul>
    <script>
        var logger = document.getElementById("messagelog");
        var conn = new WebSocket("ws://127.0.0.1:8080"); # the error is pointing here.
        conn.onOpen = function(e) {
            console.log("connection established");
        }
        conn.onMessage = function(data) {
            console.log("recieved: ", data);
        }
        conn.onError = function(e) {
            console.log("connection error:", e);
        }
        conn.onClose = function(e) {
            console.log("connection closed~");
        }
    </script>
</body>

请告诉我我错过了什么。谢谢你。

您根本没有建立协议通信。您设法接收消息，但您从未通过解析它并发送适当的响应来确认您的服务器确实是WebSocket服务器。

既然你已经在使用PHP和ZeroMQ，最简单的方法就是使用Mongrel2，它能够理解WebSocket协议，并将其传递给编码为tnetstring(类似json的编码格式，解析起来很简单)的ZeroMQ端点。

另一个解决方案是在你的代码中完全支持WebSocket协议——这超出了这个问题和答案的范围。

你不能将websocket连接到zmq套接字*，它们是不同的通信协议(websocket更像传统的套接字，zmq套接字更像是添加了额外功能的抽象)。你需要在你的服务器上设置一种方式来接收websocket连接。

*您可能能够使用RAW套接字类型使此工作，但这有点高级，除非您知道自己在做什么，否则不应该进入

。

相关内容

最新更新

热门标签：