Maison Java javaDidacticiel Guide de développement Java Websocket : Comment établir une communication en temps réel entre le client et le serveur

Guide de développement Java Websocket : Comment établir une communication en temps réel entre le client et le serveur

Dec 02, 2023 am 11:52 AM
java websocket 实时通信

Java Websocket开发指南:如何实现客户端与服务器端的实时通信

Guide de développement Java Websocket : Comment implémenter une communication en temps réel entre le client et le serveur, des exemples de code spécifiques sont nécessaires

Avec le développement continu des applications Web, la communication en temps réel est devenue une partie essentielle du projet. Dans le protocole HTTP traditionnel, le client envoie une requête au serveur et les données ne peuvent être obtenues qu'après avoir reçu la réponse. Cela amène le client à interroger en permanence le serveur pour obtenir les dernières données, ce qui entraînera des problèmes de performances et d'efficacité. . WebSocket est né pour résoudre ces problèmes.

WebSocket est un nouveau protocole en HTML5. Il fournit une communication bidirectionnelle et réduit le travail d'interrogation des clients. Le client peut envoyer des messages directement au serveur sans attendre une réponse du serveur. Cela rend le développement d’applications en temps réel plus facile et plus efficace.

Java, en tant que langage largement utilisé dans le développement d'applications Web, offre également un moyen d'implémenter facilement des Websockets. Voici comment utiliser les Websockets en Java.

La première étape consiste à importer l’API WebSocket de Java. Vous pouvez le faire à partir du référentiel central Maven ou en utilisant l'API du package javax.websocket du framework Java EE 7.

Voici un exemple d'implémentation de Websocket à l'aide de l'API dans le package javax.websocket dans Java EE 7 :

  1. Créez la classe d'annotation ServerEndpoint

Créez la classe à l'aide de l'annotation @WebSocket pour indiquer au serveur Java que cette classe peut transférer cette session En tant que point de terminaison WebSocket et en fournissant un URI, faites correspondre cette adresse au point de terminaison WebSocket.

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
 
@ServerEndpoint(value = "/websocket")
public class WebSocketExample {
     
    @OnOpen
    public void onOpen(){
        System.out.println("Connection opened");
    }
     
    @OnClose
    public void onClose(){
        System.out.println("Connection closed");
    }
     
    @OnMessage
    public void onMessage(String message){
        System.out.println("Message received: " + message);
    }
}
Copier après la connexion

Utilisez la classe WebSocketExample comme entrée de notre programme WebSocket. Dans l'exemple ci-dessus, nous avons utilisé l'annotation @ServerEndpoint avec la classe Endpoint pour mapper la classe à l'URI spécifié.

Les annotations @OnOpen, @OnMessage et @OnClose sont basées sur des événements et sont utilisées pour spécifier les méthodes à appeler lorsqu'une connexion WebSocket est ouverte, qu'un message est reçu et que la connexion est fermée.

La chaîne de message obtenue sera transmise directement à la méthode de rappel onMessage. Nous avons maintenant défini les points de terminaison côté serveur WebSocket.

  1. Créer un exemple de client
public class WebSocketClientExample extends Endpoint {
 
    public static CountDownLatch latch;
 
    @Override
    public void onOpen(final Session session, EndpointConfig config) {
        System.out.println("Connected");
 
        try {
            session.getBasicRemote().sendText("Hello");
        } catch (IOException ex) {
        }
    }
 
    @Override
    public void onError(final Session session, Throwable t) {
        t.printStackTrace();
    }
}
Copier après la connexion

Notre client WebSocket peut utiliser javax.websocket.Endpoint comme classe de base, qui fait partie de l'API WebSocket.

Nous utiliserons CountDownLatch pour déterminer si le client est connecté au serveur.

Dans la méthode de rappel onOpen(), nous nous sommes connectés au serveur et avons envoyé le message.

Remarque : dans cet exemple, le message est envoyé à l'aide de la méthode session.getBasicRemote().sendText("Hello"); Dans l'API WebSocket, il existe une autre méthode pour envoyer des messages, à savoir session.getAsyncRemote().sendText("Hello");. La différence est que la méthode getBasicRemote() est bloquante, tandis que la méthode getAsyncRemote() est non bloquante. . de. Si nous voulons envoyer des messages de manière asynchrone, nous pouvons utiliser getAsyncRemote().

  1. Créez une classe de test et exécutez l'application

Créez une classe de test pour servir le serveur et le client afin d'assurer l'établissement normal de la connexion. Vous devez démarrer l'application et laisser l'application en cours d'exécution interagir avec le serveur WebSocket. Si tout va bien, vous devriez voir des messages imprimés sur la console de l'outil de développement.

import javax.websocket.*;
import java.net.URI;
import java.util.concurrent.CountDownLatch;
 
public class AppRunner {
 
    public static void main(String[] args) throws Exception {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
 
        CountDownLatch latch = new CountDownLatch(1);
 
        container.connectToServer(new WebSocketExample(), new URI("ws://localhost:8080/websocket"));
 
        latch.await();
    }
}
Copier après la connexion

Ce code de test démarrera le client WebSocket et tentera de se connecter au serveur WebSocket sur localhost:8080. Nous utiliserons un objet CountDownLatch pour attendre une connexion réussie ainsi que quelques informations supplémentaires.

Lors de l'exécution du test, nous pouvons taper http://localhost:8080/websocket via un navigateur Web et ouvrir la console JavaScript pour afficher et envoyer des messages au client WebSocket via l'objet JavaScript WebSocket.

Résumé :

L'utilisation de WebSocket pour la communication en temps réel est bien plus efficace que l'utilisation d'interrogations périodiques HTTP traditionnelles. En langage Java, vous pouvez utiliser l'API WebSocket pour implémenter Websocket. Cet article fournit un exemple de programme Java pour le serveur et le client WebSocket ainsi que des exemples spécifiques d'implémentation de code. J'espère qu'il sera utile aux lecteurs.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

Outils d'IA chauds

Undresser.AI Undress

Undresser.AI Undress

Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover

AI Clothes Remover

Outil d'IA en ligne pour supprimer les vêtements des photos.

Undress AI Tool

Undress AI Tool

Images de déshabillage gratuites

Clothoff.io

Clothoff.io

Dissolvant de vêtements AI

AI Hentai Generator

AI Hentai Generator

Générez AI Hentai gratuitement.

Article chaud

R.E.P.O. Crystals d'énergie expliqués et ce qu'ils font (cristal jaune)
2 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Repo: Comment relancer ses coéquipiers
4 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: Comment obtenir des graines géantes
4 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Combien de temps faut-il pour battre Split Fiction?
3 Il y a quelques semaines By DDD

Outils chauds

Bloc-notes++7.3.1

Bloc-notes++7.3.1

Éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise

SublimeText3 version chinoise

Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1

Envoyer Studio 13.0.1

Puissant environnement de développement intégré PHP

Dreamweaver CS6

Dreamweaver CS6

Outils de développement Web visuel

SublimeText3 version Mac

SublimeText3 version Mac

Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Racine carrée en Java Racine carrée en Java Aug 30, 2024 pm 04:26 PM

Guide de la racine carrée en Java. Nous discutons ici du fonctionnement de Square Root en Java avec un exemple et son implémentation de code respectivement.

Nombre parfait en Java Nombre parfait en Java Aug 30, 2024 pm 04:28 PM

Guide du nombre parfait en Java. Nous discutons ici de la définition, comment vérifier le nombre parfait en Java ?, des exemples d'implémentation de code.

Générateur de nombres aléatoires en Java Générateur de nombres aléatoires en Java Aug 30, 2024 pm 04:27 PM

Guide du générateur de nombres aléatoires en Java. Nous discutons ici des fonctions en Java avec des exemples et de deux générateurs différents avec d'autres exemples.

Weka en Java Weka en Java Aug 30, 2024 pm 04:28 PM

Guide de Weka en Java. Nous discutons ici de l'introduction, de la façon d'utiliser Weka Java, du type de plate-forme et des avantages avec des exemples.

Numéro Armstrong en Java Numéro Armstrong en Java Aug 30, 2024 pm 04:26 PM

Guide du numéro Armstrong en Java. Nous discutons ici d'une introduction au numéro d'Armstrong en Java ainsi que d'une partie du code.

Numéro de Smith en Java Numéro de Smith en Java Aug 30, 2024 pm 04:28 PM

Guide du nombre de Smith en Java. Nous discutons ici de la définition, comment vérifier le numéro Smith en Java ? exemple avec implémentation de code.

Questions d'entretien chez Java Spring Questions d'entretien chez Java Spring Aug 30, 2024 pm 04:29 PM

Dans cet article, nous avons conservé les questions d'entretien Java Spring les plus posées avec leurs réponses détaillées. Pour que vous puissiez réussir l'interview.

Break or Return of Java 8 Stream Forach? Break or Return of Java 8 Stream Forach? Feb 07, 2025 pm 12:09 PM

Java 8 présente l'API Stream, fournissant un moyen puissant et expressif de traiter les collections de données. Cependant, une question courante lors de l'utilisation du flux est: comment se casser ou revenir d'une opération FOREAK? Les boucles traditionnelles permettent une interruption ou un retour précoce, mais la méthode Foreach de Stream ne prend pas directement en charge cette méthode. Cet article expliquera les raisons et explorera des méthodes alternatives pour la mise en œuvre de terminaison prématurée dans les systèmes de traitement de flux. Lire plus approfondie: Améliorations de l'API Java Stream Comprendre le flux Forach La méthode foreach est une opération terminale qui effectue une opération sur chaque élément du flux. Son intention de conception est

See all articles