Связь с другой стороной была потеряна нечистым способом
Я пытался создать простое приложение на основе 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().
Любая помощь с любой настройкой (они достигают той же цели для меня) будет оценена.:)