0

ラズベリーパイから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');
    });

});
4

1 に答える 1