Связь с другой стороной была потеряна нечистым способом

Я пытался создать простое приложение на основе WAMP RPC с использованием Autobahn(JavaScript) и Crossbar, но оно давало мне следующие ошибки:-

Трассировка перекладины:-

[Router      32589 crossbar.router.protocol.WampWebSocketServerProtocol] connection accepted from peer tcp4:[ip_address]:7110
[Router      32589 crossbar.router.protocol.WampWebSocketServerProtocol] Connection made to tcp4:[ip_address]:7110
[Router      32589 crossbar.router.protocol.WampWebSocketServerProtocol] dropping connection to peer tcp4:[ip_address]:7110 with abort=True: WebSocket opening handshake timeout (peer did not finish the opening handshake in time)
[Router      32589 crossbar.router.protocol.WampWebSocketServerProtocol] Connection to/from tcp4:[ip_address]:7110 was aborted locally
[Router      32589 crossbar.router.protocol.WampWebSocketServerProtocol] _connectionLost: [Failure instance: Traceback (failure with no frames): <class 'twisted.internet.error.ConnectionAborted'>: Connection was aborted locally using ITCPTransport.abortConnection.

Журнал консоли JavaScript:-

autobahn.min.js:90 using WAMP transport type: websocket
autobahn.min.js:181 WebSocket connection to 'ws://[domain]:8081/' failed: Error in connection establishment: net::ERR_CONNECTION_RESET
autobahn.min.js:87 connection closed unreachable {reason: null, message: null, retry_delay: null, retry_count: null, will_retry: false}
main.js:43 Connection closed.

Это код, который я запускаю:-

Перекладина config.json:-

{
    "$schema": "https://raw.githubusercontent.com/crossbario/crossbar/master/crossbar.json",
    "version": 2,
    "controller": {
    },
    "workers": [
        {
            "type": "router",
            "realms": [
                {
                    "name": "name_1",
                    "roles": [
                        {
                            "name": "anonymous",
                            "permissions": [
                                {
                                    "uri": "",
                                    "match": "prefix",
                                    "allow": {
                                        "call": true,
                                        "register": true,
                                        "publish": true,
                                        "subscribe": true
                                    },
                                    "disclose": {
                                        "caller": false,
                                        "publisher": false
                                    },
                                    "cache": false
                                }
                            ]
                        }
                    ]
                }
            ],
            "transports": [
                {
                    "type": "websocket",
                    "endpoint": {
                        "type": "tcp",
                        "port": 8081
                    },
                    "url": "ws://[domain]",
                    "serializers": ["json"],
                    "options": {
                        "allowed_origins": ["*"],
                        "allow_null_origin": true,
                        "enable_webstatus": false,
                        "max_frame_size": 1048576,
                        "max_message_size": 1048576,
                        "auto_fragment_size": 65536,
                        "fail_by_drop": true,
                        "open_handshake_timeout": 2500,
                        "close_handshake_timeout": 1000,
                        "auto_ping_interval": 10000,
                        "auto_ping_timeout": 5000,
                        "auto_ping_size": 4,
                        "compression": {
                            "deflate": {
                                "request_no_context_takeover": false,
                                "request_max_window_bits": 13,
                                "no_context_takeover": false,
                                "max_window_bits": 13,
                                "memory_level": 5
                            }
                        }
                    }
                }
            ]
        }
    ]
}

JavaScript:-

var connection=null;
AUTOBAHN_DEBUG = true;

require.config({
  baseUrl: ".",
  paths: {
      "autobahn":
         "https://[domain]/path/to/autobahn.min.js",
      "when": "https://cdnjs.cloudflare.com/ajax/libs/when/2.7.1/when"
  },
  shim: {
      "autobahn": {
          deps: ["when"]
      }
  }
});
    
require(["autobahn"], function(autobahn) {
  console.log("Ok, Autobahn loaded", autobahn.version);

  var connection = new autobahn.Connection({
    transports: [{
       type: 'websocket',
       port: '8081',
       host: '[domain]',
       url: "ws://[domain]:8081",
    }],
    realm: "name_1",
    max_retries: "0"
  });

  connection.onopen = function (session, details) {
     // Publish, Subscribe, Call and Register
      // session.register('com.myapp.add2', add2);
      // session.call('com.myapp.add2', [2, 3]).then(function showSum(res) {
      //    console.log('sum is', res);
      // }, session.log);
      console.log("Connection opened.");
  };


  connection.onclose = function (reason, details) {
     console.log("Connection closed.");
  }

  connection.open();
});

Я пытаюсь заставить эту простую вещь работать уже больше недели и не могу понять, чего не хватает.

Заранее спасибо за помощь!

РЕДАКТИРОВАТЬ: проверил то же соединение с python (код ниже), работает фантастически! Но мне это очень нужно для работы в браузере.

        from twisted.internet import reactor
        from twisted.internet.defer import inlineCallbacks
        from twisted.internet.endpoints import TCP4ClientEndpoint
        from twisted.application.internet import ClientService

        from autobahn.wamp.types import ComponentConfig
        from autobahn.twisted.wamp import ApplicationSession, WampWebSocketClientFactory

        
        class MyAppSession(ApplicationSession):

            def __init__(self, config):
                ApplicationSession.__init__(self, config)

            def onConnect(self):
                self.join(self.config.realm)

            def onChallenge(self, challenge):
                pass

            @inlineCallbacks
            def onJoin(self, details):
                yield self.call('update_price', price)
                yield self.leave()

            def onLeave(self, details):
                self.disconnect()

            def onDisconnect(self):
                reactor.stop()

        session = MyAppSession(ComponentConfig('name_1', {}))

        transport = WampWebSocketClientFactory(session, url='ws://[domain]:8081')

        endpoint = TCP4ClientEndpoint(reactor, '[domain]', 8081)

        service = ClientService(endpoint, transport)
        service.startService()

        reactor.run()

Я протестировал тот же самый JS-код, который разместил в начале на localhost, и он сработал! Итак, в процессе исключения я сузил его до проблемы подключения браузера к серверу (python может подключаться к серверу, а js может подключаться к localhost)

Кроме того, в качестве вторичного решения я мог бы запустить это только на python, но у меня уже есть другое соединение, и они оба мне нужны для связи друг с другом. Я пробовал использовать многопроцессорность, но, похоже, по какой-то причине она не работает (но работает, когда я отключаю другое соединение), даже не вызывает никаких ошибок, я пробовал try-except и pipe().

Любая помощь с любой настройкой (они достигают той же цели для меня) будет оценена.:)

0 ответов

Другие вопросы по тегам