问如何将WSO2CEP与Socket.io连接？

EN

因为我不能直接连接到socket.io，所以我创建了一个简单的websocket，它充当了一个中间件，将输入从WSO2CEP发送到socket.io。

var io = require('socket.io').listen(server);
io.set('origins', '*:*');

var WebSocketServer = require('ws').Server, 
   wss = new WebSocketServer({ port: 8087 })

//wss sending every message that it received to the socket.io
wss.on('connection', function connection(ws) {
  console.log('a WSO2CEP-PUBLISHER is connected');
  ws.on('message', function incoming(message) {
    console.log('received: %s', message);
    io.emit('input-message', JSON.parse(message));
  });
});

请注意，来自事件发布服务器的数据是字符串格式的，因此如果需要将其作为JSON对象发送，请使用JSON.parse()函数。

如果我没听错你的问题，

• 当事件从CEP服务器发布时，您不会收到任何错误。
• 但是socket io服务器也没有显示它收到事件的任何指示。

没有显示错误日志的CEP服务器意味着：

• CEP服务器已成功连接到socket io服务器。(如果删除了连接，那么您应该会看到一个错误日志，CEP将尝试重新连接)
• 该事件可能是由Websocket发送到socket服务器(或者Websocket根本没有接收到任何要发送到socket服务器的事件)
  • (当您发送一个事件时，如果CEP服务器不能解析该事件，那么您也应该会看到一个错误日志。)

​

以下是一些可以帮助您解决问题的要点：

1. 在websocket (您可以参考这个“事件跟踪器”文档)中启用跟踪。然后发送一个事件并检查跟踪。这将允许您验证是否接收到该事件。
2. 如果发布服务器显示了跟踪，但在socket服务器上仍未收到任何事件，则可能发生在socket服务器上的一些错误，并且没有记录异常(可能已被吞食)。

希望这能帮上忙。