Comment utiliser l'interface WebSocket d'Upbit?

L'interface WebSocket d'Upbit propose des données de marché en temps réel, permettant des transactions rapides; Ce guide couvre la configuration, l'abonnement et la gestion des données pour un échange efficace.

Apr 14, 2025 at 10:35 pm

L'utilisation de l'interface WebSocket d'Upbit peut améliorer considérablement votre capacité à recevoir des données de marché en temps réel et à exécuter des transactions avec un retard minimal. Cet article vous guidera tout au long du processus de configuration et d'utilisation de l'interface WebSocket d'Upbit, couvrant tout, de la connexion initiale à la gestion des données en temps réel.

Comprendre l'interface WebSocket d'Upbit

L'interface WebSocket d'Upbit est conçue pour fournir des données de marché en temps réel, y compris les mises à jour des livres de commandes, les exécutions commerciales et d'autres informations critiques. Contrairement aux API RESTful, qui nécessitent un sondage périodique, les connexions WebSocket conservent un lien persistant, permettant une transmission immédiate de données au fur et à mesure que les événements se produisent. Ceci est particulièrement utile pour les applications nécessitant des mises à jour en temps réel, telles que les bots de trading et les outils d'analyse du marché.

Configuration de la connexion WebSocket

Pour établir une connexion avec le serveur WebSocket d'Upbit, vous devrez utiliser une bibliothèque client WebSocket. De nombreux langages de programmation offrent de telles bibliothèques, notamment JavaScript, Python et Java. Voici comment configurer une connexion à l'aide de la bibliothèque websocket-client de Python:

• Installez la bibliothèque client WebSocket : vous pouvez le faire en exécutant pip install websocket-client dans votre terminal.
• Importez les modules nécessaires : dans votre script Python, ajoutez import websocket .
• Définissez l'URL WebSocket : l'URL WebSocket d'Upbit est wss://api.upbit.com/websocket/v1 .
• Établissez la connexion : utilisez la fonction websocket.create_connection() pour vous connecter à l'URL WebSocket.

Voici un exemple d'extrait de code pour établir la connexion:

 import websocket ws = Websocket.create_connection ('wss: //api.upbit.com/websocket/v1')

Souscrit aux données du marché

Une fois connecté, vous devez vous abonner aux données de marché spécifiques qui vous intéressent. Upbit vous permet de vous abonner à divers types de données, tels que les mises à jour du livre de commandes, les tiques commerciales et les données de ticker.

• Envoyez une demande d'abonnement : Après avoir établi la connexion, envoyez une demande d'abonnement Formatted JSON. Par exemple, pour vous abonner au carnet de commandes de la paire BTC / KRW, vous enverriez:

 {
 'type': 'subscribe',
 'channels': [ { 'name': 'orderbook', 'symbols': ['KRW-BTC'] }

]]
}

• Envoyez la demande d'abonnement à l'aide de Python : utilisez la méthode ws.send() pour envoyer la demande d'abonnement.

 subscription = {
 'type': 'subscribe',
 'channels': [ { 'name': 'orderbook', 'symbols': ['KRW-BTC'] }

]]
}
Ws.Send (JSON.Dumps (abonnement))

Gérer les données en temps réel

Une fois abonné, vous commencerez à recevoir des données en temps réel d'Upbit. Vous devez configurer un mécanisme pour traiter ces données efficacement.

• Configurez une boucle pour recevoir des messages : utilisez une boucle pour recevoir en continu des messages de la connexion WebSocket. Dans Python, vous pouvez utiliser la méthode ws.recv() pour recevoir des données.

 import json Bien que vrai:



result = ws.recv() data = json.loads(result) print(data)
 Analyser et traiter les données reçues : Selon le type de données reçues, vous devrez l'analyser et les traiter en conséquence. Par exemple, si vous recevez des données de carnet de commandes, vous souhaiterez peut-être mettre à jour votre représentation locale de carnet de commandes.
 Gérer la connexion
 La maintenance d'une connexion WebSocket stable est cruciale pour les applications en temps réel. Voici quelques conseils pour gérer la connexion:
 
Implémentez la logique de reconnexion : si la connexion est perdue, votre application doit tenter de se reconnecter. Vous pouvez utiliser un bloc d'essai à l'exception pour gérer les erreurs de connexion et tenter de vous reconnecter.
 while True: try: ws = websocket.create_connection('wss://api.upbit.com/websocket/v1') # Send subscription requests and handle data except websocket.WebSocketException as e: print(f'WebSocket error: {e}') time.sleep(5) # Wait for 5 seconds before retrying
 Gérer WebSocket Ping / Pong : le serveur WebSocket d'Upbit peut envoyer des messages Ping pour maintenir la connexion en vie. Assurez-vous que votre client répond à ces pings avec des messages Pong pour maintenir la connexion.
 Débranchement des données du marché
 Si vous n'avez plus besoin de recevoir certaines données, vous pouvez vous désinscrire. Cela aide à gérer le flux de données et à réduire le trafic réseau inutile.
 
Envoyez une demande de désabonnement : similaire à l'abonnement, vous devez envoyer une demande de désabonnement Formatted JSON. Par exemple, pour se désabonner du carnet de commandes de la paire BTC / KRW, vous enverriez:
 {
 «Type»: «désinscription»,
 «canaux»: [
 
{ 'name': 'orderbook', 'symbols': ['KRW-BTC'] }
 ]]
 }

• Envoyez la demande de désabonnement à l'aide de Python : utilisez la méthode ws.send() pour envoyer la demande de désabonnement.

 unsubscription = {
 'type': 'unsubscribe',
 'channels': [ { 'name': 'orderbook', 'symbols': ['KRW-BTC'] }

]]
}
Ws.Send (JSON.Dumps (Discription))

Clôture de la connexion WebSocket

Lorsque vous avez terminé en utilisant la connexion WebSocket, il est important de le fermer correctement pour libérer les ressources.

• Fermez la connexion : utilisez la méthode ws.close() pour fermer la connexion WebSocket.

 ws.close()

Questions fréquemment posées

Q: Puis-je m'abonner à plusieurs marchés à la fois en utilisant l'interface WebSocket d'Upbit?

R: Oui, vous pouvez vous abonner à plusieurs marchés en incluant plusieurs symboles dans votre demande d'abonnement. Par exemple, pour vous abonner aux livres de commandes BTC / KRW et ETH / KRW, vous enverriez:

 {
 'type': 'subscribe',
 'channels': [ { 'name': 'orderbook', 'symbols': ['KRW-BTC', 'KRW-ETH'] }

]]
}

Q: Comment puis-je gérer la limitation des taux avec l'interface WebSocket d'Upbit?

R: L'interface WebSocket d'Upbit n'a pas de limites de taux explicites comme les API RESTful. Cependant, pour éviter de submerger le serveur, vous devez gérer efficacement vos abonnements et le traitement des données. Si vous rencontrez des problèmes, envisagez de réduire le nombre d'abonnements ou de mettre en œuvre une stratégie de revers.

Q: Est-il possible de recevoir à la fois des données commerciales et de commandes via la même connexion WebSocket?

R: Oui, vous pouvez vous abonner à plusieurs types de données via la même connexion WebSocket. Par exemple, pour recevoir à la fois des données sur le commerce et le livre de commandes pour BTC / KRW, vous enverriez:

 {
 'type': 'subscribe',
 'channels': [ { 'name': 'orderbook', 'symbols': ['KRW-BTC'] }, { 'name': 'trade', 'symbols': ['KRW-BTC'] }

]]
}

Q: Comment puis-je m'assurer que ma connexion WebSocket reste stable sur de longues périodes?

R: Pour assurer la stabilité, implémentez la logique de reconnexion pour gérer les déconnexions, gérez les messages WebSocket Ping / Pong pour maintenir la connexion en vie et surveiller les performances de votre application pour éviter l'épuisement des ressources.