ラズベリーパイからpython socket ioルーチンによって呼び出されるNode.js socket.ioルーチンを作成しました。双方向で通信します。これら 2 つのルーチンを localhost で実行すると、問題なく動作します。ただし、サーバー アプリケーションを cloudfoundry にデプロイし、SocketIO 接続リンクを cloudfoundry に変更すると、機能しません。以下はクライアントのpythonです
from socketIO_client import SocketIO
def on_updatepi_response(*args):
print 'updatepi'
def on_receivepi_response(*args):
print 'receiveepi'
with SocketIO('raspinode-server.cloudfoundry.com', 8080) as socketIO:
socketIO.on('receivepi', on_receivepi_response)
socketIO.on('updatepi', on_updatepi_response)
socketIO.emit('sendrabbit','testdata')
socketIO.wait(seconds=1)
私の最初のアイデアはrabbitmqを使用することでしたが、それはVCAP_SERVICESのアイデアに結びついています。しかし、Node.js ページにそのような制限があるとは思いませんでした。
上記のコードに何か問題があるかどうか教えてください。そうでない場合は、どうすれば外部 pi からクラウド アプリに読み取り値を送信できますか?
関係ありませんが、サーバーコードを以下に示します。localhost で応答します... rabbitmq コードがまだ接続されていないことはわかっています
var express = require('express');
var app = express();
var server = require('http').createServer(app);
var amqp = require('amqp');
var io = require('socket.io').listen(server)
function rabbitUrl() {
if (process.env.VCAP_SERVICES) {
conf = JSON.parse(process.env.VCAP_SERVICES);
return conf['rabbitmq-2.4'][0].credentials.url;
}
else {
return "amqp://localhost";
}
}
var port = process.env.VCAP_APP_PORT || 3000;
var messages = [];
function setup() {
var exchange = conn.exchange('cf-demo', {'type':'fanout', durable:false}, function(){
var queue = conn.queue('', {durable:false, exclusive:true},
function() {
queue.subscribe(function(msg) {
messages.push(htmlEscape(msg.body));
if (messages.length > 10) {
messages.shift();
}
});
queue.bind(exchange.name, '');
});
queue.on('queueBindOk', function() {httpServer(exchange);});
});
}
server.listen(8080);
io.sockets.on('connection', function(socket){
// when the client emits sendrabbit, this listens
socket.on('sendrabbit', function(data)
{
// we tell the client to execute updatepi with 2 parameters
io.sockets.emit('updatepi', socket.username, data)
});
socket.on('disconnect', function()
{
socket.broadcast.emit('updatepi', 'SERVER', socket.username + ' has disconnected');
});
});