如何在每个会话的基础上限制高速公路python订阅

Question

我在服务器端使用带扭曲（wamp）的高速公路和浏览器中的高速公路。是否有一种直接的方法允许/限制每个会话的订阅？例如，客户机不应该订阅与其他用户相关的主题。在

当我不使用横杆io，我尝试使用本页末尾的“Example”部分中显示的Python代码，http://crossbar.io/docs/Authorization/首先使用RPC调用向客户机授予授权。当然，我使用我自己的授权逻辑。一旦此授权成功，我将授予客户端特权，以订阅仅与此客户端相关的主题，如'com.example.user用户名'. 但是，我的问题是，即使auth通过，我也没有找到一种方法来限制ApplicationSession类中的订阅请求，而ApplicationSession类是进行授权的地方。我如何防止授权给user_id=user_a的客户订阅'com.example.user\b'? 在

Answer 1

我发现了一个使用Node-guest的相对简单的解决方案。代码如下：

    // crossbar setup
var autobahn = require('autobahn');

var connection = new autobahn.Connection({
        url: 'ws://127.0.0.1:8080/ws',
        realm: 'realm1'
    }
);

// Websocket to Scratch setup
// pull in the required node packages and assign variables for the entities
var WebSocketServer = require('websocket').server;
var http = require('http');

var ipPort = 1234; // ip port number for Scratch to use

// this connection is a crossbar connection
connection.onopen = function (session) {

    // create an http server that will be used to contain a WebSocket server
    var server = http.createServer(function (request, response) {
        // We are not processing any HTTP, so this is an empty function. 'server' is a wrapper for the
        // WebSocketServer we are going to create below.
    });

    // Create an IP listener using the http server
    server.listen(ipPort, function () {
        console.log('Webserver created and listening on port ' + ipPort);
    });

    // create the WebSocket Server and associate it with the httpServer
    var wsServer = new WebSocketServer({
        httpServer: server
    });

    // WebSocket server has been activated and a 'request' message has been received from client websocket
    wsServer.on('request', function (request) {
        // accept a connection request from Xi4S
        //myconnection is the WS connection to Scratch
        myconnection = request.accept(null, request.origin); // The server is now 'online'

        // Process Xi4S messages
        myconnection.on('message', function (message) {

            console.log('message received: ' + message.utf8Data);
            session.publish('com.serial.data', [message.utf8Data]);

            // Process each message type received
            myconnection.on('close', function (myconnection) {
                console.log('Client closed connection');
                boardReset();
            });
        });
    });
};

connection.open();