WebSocket.exceptions.InvalidStatusCode:服务器拒绝了WebSocket连接：HTTP 400

Question

我无法使用^{} module连接到websocket。我有以下代码：

import asyncio, ssl
import websockets


headers= {
        'Accept-Encoding': 'gzip, deflate, br',
        'Accept-Language': 'en-US,en;q=0.9',
        'Cache-Control': 'no-cache',
        'Connection': 'Upgrade',
        'Host': ...,
        'Origin': ...,
        'Pragma': 'no-cache',
        'Upgrade': 'websocket',
        'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.106 Safari/537.36'
    }

async def hello():
    uri = ...
    async with websockets.connect(ssl=0,
                                  extra_headers=headers,
                                  origin="*",
                                  uri = uri) as websocket:
        pass

asyncio.get_event_loop().run_until_complete(hello())

我得到以下例外情况：

Traceback (most recent call last):
  File "C:\Users\AFMN\AppData\Local\Programs\Python\Python38-32\kr ws.py", line 30, in <module>
    asyncio.get_event_loop().run_until_complete(hello())
  File "C:\Users\AFMN\AppData\Local\Programs\Python\Python38-32\lib\asyncio\base_events.py", line 616, in run_until_complete
    return future.result()
  File "C:\Users\AFMN\AppData\Local\Programs\Python\Python38-32\kr ws.py", line 19, in hello
    async with websockets.connect(ssl=0,
  File "C:\Users\AFMN\AppData\Local\Programs\Python\Python38-32\lib\site-packages\websockets\client.py", line 517, in __aenter__
    return await self
  File "C:\Users\AFMN\AppData\Local\Programs\Python\Python38-32\lib\site-packages\websockets\client.py", line 542, in __await_impl__
    await protocol.handshake(
  File "C:\Users\AFMN\AppData\Local\Programs\Python\Python38-32\lib\site-packages\websockets\client.py", line 296, in handshake
    raise InvalidStatusCode(status_code)
websockets.exceptions.InvalidStatusCode: server rejected WebSocket connection: HTTP 400

但问题是，我可以使用^{} module连接到websocket，但由于几个原因，我不想使用它。但是如果有帮助，下面是使用websocket的代码：

import websocket, ssl
try:
    import thread
except ImportError:
    import _thread as thread
import time, msgpack

headers= {
        'Accept-Encoding': 'gzip, deflate, br',
        'Accept-Language': 'en-US,en;q=0.9',
        'Cache-Control': 'no-cache',
        'Connection': 'Upgrade',
        'Host': ...,
        'Origin': ...,
        'Pragma': 'no-cache',
        'Upgrade': 'websocket',
        'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/83.0.4103.106 Safari/537.36'
    }

def on_message(ws, message):
    ...

def on_error(ws, error):
    ...

def on_close(ws):
    ...

def on_open(ws):
    ...


if __name__ == "__main__":
    websocket.enableTrace(True)
    ws = websocket.WebSocketApp(...,
                              on_message = on_message,
                              on_error = on_error,
                              on_close = on_close,
                              header=headers,
                              subprotocols=["binary", "base64"])
    ws.on_open = on_open
    ws.run_forever(sslopt={"cert_reqs": ssl.CERT_NONE})

为什么我不能在第一个代码中连接到websocket，而我可以使用另一个模块连接到同一个websocket

如何使用第一个连接

Answer 1

你的网址是什么？看起来该服务器只支持TLS上的WebSocket，所以应该使用wss://而不是ws://