LBANK의 WebSocket API를 사용하는 방법은 무엇입니까?

LBANK의 WebSocket API를 사용하면 실시간 데이터를 수신하고 거래를보다 효율적으로 실행하는 효과적인 방법이 될 수 있습니다. 이 기사에서는 인기있는 cryptocurrency 교환 인 Lbank가 제공하는 WebSocket API를 설정하고 사용하는 과정을 안내합니다. 이 세부 가이드를 따르면 실시간 시장 데이터 및 거래 기능을 응용 프로그램에 통합 할 수 있습니다.

WebSocket API 기본 사항 이해

LBANK의 WebSocket API의 세부 사항을 다이빙하기 전에 WebSocket API가 무엇인지, 기존 HTTP 요청과 어떻게 다른지 이해하는 것이 중요합니다. WebSocket API는 단일 TCP 연결을 통한 전이중 통신 채널을 제공하여 클라이언트와 서버간에 실시간 데이터 전송이 가능합니다. 이것은 적시에 업데이트가 중요 할 수있는 cryptocurrency 거래 공간에서 특히 유용합니다.

LBANK의 WebSocket API를 통해 사용자는 가격 업데이트, 주문서 변경 및 거래 실행과 같은 실시간 시장 데이터를 구독 할 수 있습니다. API 사용을 시작하려면 LBANK 서버에 대한 WebSocket 연결을 설정해야합니다.

WebSocket 연결을 설정합니다

시작하려면 LBANK의 WebSocket 서버에 연결해야합니다. 당신이 할 수있는 방법은 다음과 같습니다.

• WebSocket 라이브러리 선택 : 프로그래밍 언어에는 WebSocket 라이브러리가 필요합니다. 인기있는 선택에는 Python 용 websocket-client , Node.js 용 ws 및 Java 용 WebSocket 포함됩니다.
• 서버에 연결하십시오 : lbank의 WebSocket 엔드 포인트는 wss://api.lbkex.com/ws 입니다. 선택한 라이브러리를 사용 하여이 엔드 포인트에 대한 연결을 설정하십시오.

websocket-client 라이브러리를 사용하여 Python의 예는 다음과 같습니다.

 import websocket def on_open (WS) :

print('Opened connection')
 def on_message (ws, message) :
 
print(message)
 def on_error (WS, 오류) :
 
print(error)
 def on_close (ws, close_status_code, close_msg) :
 
print('Closed connection')
 이름 == '__main__':
 
websocket.enableTrace(True) ws = websocket.WebSocketApp('wss://api.lbkex.com/ws', on_open=on_open, on_message=on_message, on_error=on_error, on_close=on_close) ws.run_forever()
 시장 데이터에 가입
 연결이 설정되면 다양한 유형의 시장 데이터를 구독 할 수 있습니다. LBank의 WebSocket API는 다음을 포함하여 여러 유형의 구독을 지원합니다.
 

• 시세 데이터 : 특정 거래 쌍에 대한 실시간 가격 업데이트.
• 주문서 데이터 : 주문서의 현재 상태에 대한 실시간 업데이트.
• 거래 데이터 : 실행 된 거래에 대한 실시간 업데이트.

이러한 데이터 스트림을 구독하려면 JSON 형식의 메시지를 WebSocket 서버로 보내야합니다. BTC/USDT 쌍의 Ticker 데이터를 구독하는 방법은 다음과 같습니다.

{

'sub': 'market.btcusdt.ticker', 'ID': '12345' }

WebSocket 연결을 통해이 메시지를 보내십시오.

 ws.send(json.dumps({ 'sub': 'market.btcusdt.ticker', 'id': '12345'

}))

실시간으로 시세 데이터를 받게되며 on_message 기능에서 처리 할 수 ​​있습니다.

수신 된 데이터를 처리합니다

WebSocket API에서 데이터를 수신하면 JSON 형식이됩니다. 다음은 시세 데이터를 처리하는 방법의 예입니다.

 import json def on_message (ws, message) :

data = json.loads(message) if 'ch' in data and data['ch'] == 'market.btcusdt.ticker': ticker = data['tick'] print(f'Latest Price: {ticker['close']}') print(f'24h Volume: {ticker['vol']}')
 이 코드는 JSON 메시지를 구문 분석하고 BTC/USDT 쌍의 최신 가격 및 24 시간 거래량을 추출합니다.
 
WebSocket을 통해 주문 배치
 LBANK의 WebSocket API를 사용하면 주문을 직접 배치 할 수 있습니다. 이렇게하려면 연결을 인증 한 다음 적절한 JSON 메시지를 보내야합니다. 다음은 다음과 같은 방법입니다.
 

• 인증 : API 키 및 서명으로 인증 메시지를 보내십시오.
• 주문 배치 : 필요한 매개 변수와 함께 주문 메시지를 보내십시오.

다음은 구매 주문을 인증하고 배치하는 방법의 예입니다.

import hmac

수입 시간 JSON 수입

api_key = 'Your_api_key' api_secret = 'your_api_secret'

def get_signature (timeStamp, method, request_path, body) :

payload = timestamp + method + request_path + (body or '') return hmac.new(api_secret.encode('utf-8'), payload.encode('utf-8'), digestmod='sha256').hexdigest()

DEF 인증 인증 (WS) :

timestamp = str(int(time.time() * 1000)) signature = get_signature(timestamp, 'GET', '/users/self/verify', '') auth_message = { 'op': 'auth', 'args': [api_key, timestamp, signature] } ws.send(json.dumps(auth_message))

def place_order (WS) :

order_message = { 'op': 'order', 'args': [{ 'symbol': 'btcusdt', 'type': 'buy', 'price': '30000', 'amount': '0.01' }] } ws.send(json.dumps(order_message))

이름 == '__main__':

websocket.enableTrace(True) ws = websocket.WebSocketApp('wss://api.lbkex.com/ws', on_open=lambda ws: (authenticate(ws), place_order(ws)), on_message=on_message, on_error=on_error, on_close=on_close) ws.run_forever()

이 코드는 연결을 인증 한 다음 0.01 BTC에 대한 구매 주문을 30,000 USDT의 가격으로 배치합니다.

시장 데이터에서 구독 취소

특정 데이터 스트림에 대한 업데이트 수신을 중지 해야하는 경우 구독 취소 메시지를 보내서 구독 취소 할 수 있습니다. BTC/USDT 쌍의 시세 데이터를 구독하지 않는 방법은 다음과 같습니다.

{

'Unsub': 'Market.btcusdt.ticker', 'ID': '12345' }

WebSocket 연결을 통해이 메시지를 보내십시오.

 ws.send(json.dumps({ 'unsub': 'market.btcusdt.ticker', 'id': '12345'

}))

FAQ

Q : 여러 거래 쌍에 LBANK의 WebSocket API를 동시에 사용할 수 있습니까?

A : 예, 각 쌍에 대해 별도의 구독 메시지를 보내서 여러 거래 쌍을 구독 할 수 있습니다. 예를 들어, BTC/USDT 및 ETH/USDT 시세 데이터를 모두 구독하려면 다음을 보낼 것입니다.

 { 'sub': 'market.btcusdt.ticker', 'id': '12345' }

그리고

 { 'sub': 'market.ethusdt.ticker', 'id': '12346' }

Q : WebSocket 연결이 떨어지면 어떻게해야합니까?

A : WebSocket 연결이 떨어지면 응용 프로그램이 자동으로 다시 연결하려고 시도해야합니다. 이 시나리오를 처리하기 위해 코드에서 재 연결 메커니즘을 구현할 수 있습니다. 예를 들어, 파이썬에서 :

 import time def on_error (WS, 오류) :

print(error) time.sleep(5) # Wait for 5 seconds before attempting to reconnect ws.run_forever()
 def on_close (ws, close_status_code, close_msg) :
 
print('Closed connection') time.sleep(5) # Wait for 5 seconds before attempting to reconnect ws.run_forever()
 Q : WebSocket API를 사용할 때 API 키의 보안을 어떻게 보장 할 수 있습니까?
 
A : API 키의 보안을 보장하려면 스크립트에 하드 코딩하지 마십시오. 대신 환경 변수 또는 보안 구성 파일을 사용하여 API 키와 비밀을 저장하십시오. 또한 WebSocket 연결에 항상 https (wss : //)를 사용하여 대중 교통에서 데이터를 암호화하십시오.