Python WebSocket 긴 연결 심박수와 짧은 연결의 예

설치

pip install websocket-client

먼저 긴 연결 호출 방식을 살펴보겠습니다.

ws = websocket.WebSocketApp("ws://echo.websocket.org/",
               on_message = on_message,
               on_error = on_error,
               on_close = on_close)
  ws.on_open = on_open
  ws.run_forever()

긴 연결, 매개 변수 설명:
(1)url: 웹소켓의 주소입니다.
(2)header: 고객이 웹소켓 악수 요청 헤더를 보냅니다. {'head1:value1','head2:value2'}.
(3)on_open: 웹소켓을 만들 때 사용할 수 있는 호출 대상입니다. 이 방법은 매개 변수가 하나입니다. 바로 이 종류 자체입니다.
(4)on_메시지: 이 대상은 서버가 되돌아오는 메시지를 받을 때 호출됩니다.두 개의 매개 변수가 있는데, 하나는 이 종류 자체이고, 하나는 우리가 서버에서 얻은 문자열 (utf-8 형식) 이다.
(5)on_error: 이 대상은 오류가 발생했을 때 호출됩니다. 두 개의 매개 변수가 있습니다. 첫 번째는 이 종류 자체이고, 두 번째는 이상 대상입니다.
(6)on_close: 연결이 닫힌 상황을 만났을 때 호출합니다. 매개 변수는 하나입니다. 이 종류 자체입니다.
(7)on_cont_메시지: 이 대상은 연속 프레임 데이터를 받을 때 호출됩니다. 세 가지 파라미터가 있습니다. 각각 클래스 자체, 서버에서 받은 문자열(utf-8), 연속 로고입니다.
(8)on_데이터: 서버에서 메시지를 받았을 때 호출됩니다. 이 종류 자체, 수신된 문자열(utf-8), 데이터 형식, 연속 로고 등 네 가지 파라미터가 있습니다.
(9)keep_running: 2진법의 표지 위치입니다. 만약에 True라면 이 앱의 메인 순환은 계속 실행되고 기본값은 True입니다.
(10)get_mask_키: 마스크를 만드는 데 사용됩니다.
(11)subprotocols: 기본적으로 비어 있는 하위 프로토콜 그룹입니다.
긴 연결 관건 방법: ws.run_forever(ping_interval=60,ping_timeout=5)
웹소켓 연결을 계속 닫으면 계속 막힙니다.또한 이 함수는 두 개의 매개 변수를 가지고 전송되면 심장 박동 패키지를 시작합니다.
ping_interval: "ping"명령을 자동으로 보냅니다. 지정한 시간(초)마다 보냅니다. 0으로 설정하면 자동으로 보냅니다.
ping_timeout:pong 메시지를 받지 못하면 시간 초과 (초) 입니다.

ws.run_forever(ping_interval=60,ping_timeout=5)#ping_interval #ping_timeout  ， ping pong 

우리는 소스 코드를 보면 다음과 같은 코드를 발견할 수 있다.
ping의 시간 초과 시간, ping 간격보다 크다

    if not ping_timeout or ping_timeout <= 0:
      ping_timeout = None
    if ping_timeout and ping_interval and ping_interval <= ping_timeout:
      raise WebSocketException("Ensure ping_interval > ping_timeout")

긴 연결:
예 1:

import websocket
try:
  import thread
except ImportError:
  import _thread as thread
import time

def on_message(ws, message):
  print(message)

def on_error(ws, error):
  print(error)

def on_close(ws):
  print("### closed ###")


def on_open(ws):
  def run(*args):
    ws.send("hello1")
    time.sleep(1)
    ws.close()
  thread.start_new_thread(run,())

if __name__ == "__main__":
  websocket.enableTrace(True)
  ws = websocket.WebSocketApp("ws://echo.websocket.org/",
               on_message = on_message,
               on_error = on_error,
               on_close = on_close)
  ws.on_open = on_open
  ws.run_forever(ping_interval=60,ping_timeout=5)

예 2:

import websocket
from threading import Thread
import time
import sys


class MyApp(websocket.WebSocketApp):
  def on_message(self, message):
    print(message)

  def on_error(self, error):
    print(error)

  def on_close(self):
    print("### closed ###")

  def on_open(self):
    def run(*args):
      for i in range(3):
        # send the message, then wait
        # so thread doesn't exit and socket
        # isn't closed
        self.send("Hello %d" % i)
        time.sleep(1)

      time.sleep(1)
      self.close()
      print("Thread terminating...")

    Thread(target=run).start()


if __name__ == "__main__":
  websocket.enableTrace(True)
  if len(sys.argv) < 2:
    host = "ws://echo.websocket.org/"
  else:
    host = sys.argv[1]
  ws = MyApp(host)
  ws.run_forever()

짧은 연결:

from websocket import create_connection
ws = create_connection("ws://echo.websocket.org/")
print("Sending 'Hello, World'...")
ws.send("Hello, World")
print("Sent")
print("Receiving...")
result = ws.recv()
print("Received '%s'" % result)
ws.close()

이상은 Python WebSocket의 긴 연결 심장박동과 짧은 연결의 예시에 대한 상세한 내용입니다. 더 많은 Python WebSocket 연결에 관한 자료는 저희 다른 관련 글을 주목해 주십시오!