需要Websocket升級426

Question

我運行我的程序在哪裏使用websocket連接。之前，我的程序運行正常，但今天我得到了錯誤信息websocket連接關閉不清，需要升級426.在客戶端，我使用高速公路絞線版本15.4.0，並且在服務器中，我在節點js中使用了ws websocket。 請給我一些建議。 Thankyou。

這是我的客戶端代碼：

##WebSocket Class 
class MyClientProtocol (WebSocketClientProtocol): 
    def onConnect(self, response): 
     status = "Server connected: {0}".format(response.peer) 
     logData(status) 

    def onOpen(self): 
     status ="WebSocket connection open." 
     logData (status) 

     def SentData(): 
      select() 

      if (numberOfData==0): #jika data kosong koneksi terputus 
       # if there is no data, connection will closed 
       self.sendClose() 

      else: 
       self.sendMessage (dataSent.encode('utf8')) #send data if file not empty 

     SentData() 

    def onMessage(self, payload, isBinary): 
     if isBinary: 
      print("Binary message received: {0} bytes".format(len(payload))) 
     else: 
      # if server sent ack connection will close 
      if (payload.decode('utf8')=="ok"): 
       print("Text message received") 
       status="data sent" 
       logData(status) 
       dataNew[:]=[] 

       update() 
       # get time while sent 
       #p=subprocess.Popen("date", stdout=subprocess.PIPE, shell=True) 
       #output= str(p.communicate()) 
       #logData(output) 

       self.sendClose() 

      else: 
      # if server sent nack, data will resend 
       self.sendMessage(dataSent.encode('utf8')) 

    def onClose(self, wasClean, code, reason): 
     status ="WebSocket connection closed code [{}]: {}".format(code,reason) 
     logData (status) 
     self.factory.reactor.callLater (int(interval),webSocketConnect)#send data every 10 seconds 


#websocket connection function 
def webSocketConnect(): 
    factory = WebSocketClientFactory (u"wss://node-imamabdul-2.c9.io:8080", debug=False) 
    factory.protocol = MyClientProtocol 

    reactor.connectTCP("node-imamabdul-2.c9.io",8080, factory) 

#SIGINT 
def SIGINT_CustomEventHandler(num, frame): 
    k={1:"SIGHUP", 2:"SIGINT"} 
    status="Recieved signal - " + k[num] 
    logData(status) 
    if frame is not None: 
     status="SIGINT at %s:%s"%(frame.f_code.co_name, frame.f_lineno) 
     logData(status) 
    status="In SIGINT Custom Handler Shutting Down ..." 
    logData (status) 
    if num == 2: 
     #status= "shutting down ...." 
     exitFlag=True 
     reactor.stop() 


## main 
if __name__ == '__main__': 

    readID() 

    conn = sqlite3.connect(vcspath+'vcsdb2.db') 
    cur= conn.cursor() 
    create()  
    ## global variables 
    #os.system("hwclock -w -f /dev/rtc1") 
    exitFlag = False 
    Data =[] 
    DataStatus=False 
    #makeDir() 

    webSocketConnect() 
    signal.signal(signal.SIGINT, SIGINT_CustomEventHandler) 
    reactor.run() 

這是我的服務器代碼：

var WebSocketServer = require('ws').Server 
    , wss = new WebSocketServer({ port: process.env.PORT }); 

port = process.env.PORT; 
console.log("PORT :" + port); 
wss.on('connection', function connection(wss) { 
    console.log("connection opened" + wss.listeners()); 

    wss.on('message', function incoming(message) { 
    console.log("connection has message: " + message) 
    var fs = require('fs'); 
    var timestamp = new Date().toString('hex') 
    fs.appendFile('fromclient.csv',"['"+timestamp+"']"+' ' + message+'\n') 

    wss.send(message); 

    }); 
    wss.on('close', function closeSocket() { 
    console.log("connection closed"); 
    }); 
    wss.on('error', function socketError() { 
    console.log("connection has error"); 
    }); 
}); 

Answer 1

在你的代碼使用的是加密的WebSockets連接，這裏（Python代碼）：

#websocket connection function 
def webSocketConnect(): 
    factory = WebSocketClientFactory (u"wss://node-imamabdul-2.c9.io:8080", debug=False) 
    factory.protocol = MyClientProtocol 

    reactor.connectTCP("node-imamabdul-2.c9.io",8080, factory) 

因爲您使用的高速公路15.4.0與wss，您遇到了the issue (bug) that exists in Autobahn version 15.4.0。

該問題在9天前得到修復。

您需要在修復（真正的新版本，如果它被釋放）後將Autobahn更新爲版本，或者在問題（錯誤）引入之前將Autobahn降級爲版本。

另一種選擇是使用ws而不是wss - 這意味着您的連接不會被加密，這不是建議的。

祝你好運！