Java开发：如何使用WebSocket进行实时通信-java教程-PHP中文网

Java开发：如何使用WebSocket进行实时通信

WBOY

发布： 2023-09-21 13:16:55

原创

1260人浏览过

java开发：如何使用websocket进行实时通信

Java开发：如何使用WebSocket进行实时通信

WebSocket是一种用于在Web应用程序中进行双向通信的协议。它允许服务器主动向客户端发送消息，实现实时通信的功能。在Java开发中，我们可以使用一些开源的库来实现WebSocket通信。

本文将介绍如何使用Java中的javax.websocket库来实现WebSocket通信，并提供具体的代码示例。

步骤1：引入依赖库
首先，我们需要在项目中引入javax.websocket和javax.json库的依赖。可以使用Maven来管理依赖，添加以下代码到pom.xml文件中：

立即学习“Java免费学习笔记（深入）”；

<dependencies>
  <dependency>
    <groupId>javax.websocket</groupId>
    <artifactId>javax.websocket-api</artifactId>
    <version>1.1</version>
  </dependency>
  <dependency>
    <groupId>org.glassfish.tyrus</groupId>
    <artifactId>tyrus-container-grizzly-client</artifactId>
    <version>1.13</version>
  </dependency>
  <dependency>
    <groupId>javax.json</groupId>
    <artifactId>javax.json-api</artifactId>
    <version>1.1</version>
  </dependency>
  <dependency>
    <groupId>org.glassfish</groupId>
    <artifactId>javax.json</artifactId>
    <version>1.1</version>
  </dependency>
</dependencies>

登录后复制

步骤2：创建WebSocket服务器和客户端
接下来，我们需要创建一个WebSocket服务器和一个WebSocket客户端。

企业网站通用源码1.0

企业网站通用源码是以aspcms作为核心进行开发的asp企业网站源码。企业网站通用源码是一套界面设计非常漂亮的企业网站源码，是2016年下半年的又一力作，适合大部分的企业在制作网站是参考或使用，源码亲测完整可用，没有任何功能限制，程序内核使用的是aspcms，如果有不懂的地方或者有不会用的地方可以搜索aspcms的相关技术问题来解决。网站UI虽然不是特别细腻，但是网站整体格调非常立体，尤其是通观全

查看详情

服务器端代码示例：

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint("/websocket")
public class WebSocketServer {

    @OnOpen
    public void onOpen(Session session) {
        // 当有客户端连接时触发
        System.out.println("WebSocket连接已建立");
    }

    @OnMessage
    public String onMessage(String message, Session session) {
        // 当收到客户端消息时触发，并向客户端发送消息
        System.out.println("收到客户端消息：" + message);
        return "服务器返回消息：" + message;
    }

    @OnClose
    public void onClose(Session session, CloseReason closeReason) {
        // 当客户端断开连接时触发
        System.out.println("WebSocket连接已关闭");
    }

    @OnError
    public void onError(Throwable error) {
        // 当发生错误时触发
        System.out.println("WebSocket错误：" + error.getMessage());
    }
}

登录后复制

客户端代码示例：

import javax.websocket.*;
import java.net.URI;

@ClientEndpoint
public class WebSocketClient {

    private Session session;
    private CountDownLatch latch;

    public WebSocketClient() {
        latch = new CountDownLatch(1);
    }

    @OnOpen
    public void onOpen(Session session) {
        // 当连接建立时触发
        System.out.println("WebSocket连接已建立");
        this.session = session;
        latch.countDown();
    }

    public void sendMessage(String message) {
        // 向服务器发送消息
        session.getAsyncRemote().sendText(message);
    }

    @OnMessage
    public void onMessage(String message) {
        // 当收到服务器消息时触发
        System.out.println("收到服务器消息：" + message);
    }

    @OnClose
    public void onClose(Session session, CloseReason closeReason) {
        // 当服务器断开连接时触发
        System.out.println("WebSocket连接已关闭");
    }
    
    @OnError
    public void onError(Throwable error) {
        // 当发生错误时触发
        System.out.println("WebSocket错误：" + error.getMessage());
    }
    
    public void close() throws InterruptedException {
        // 关闭WebSocket连接
        session.close();
        latch.await();
    }
}

登录后复制

步骤3：启动服务器和客户端
最后，我们需要在Main类中启动服务器和客户端。

public class Main {
    public static void main(String[] args) {
        WebSocketServer server = new WebSocketServer();
        ServerContainer serverContainer = ContainerProvider.getWebSocketContainer();
        try {
            serverContainer.connectToServer(server, new URI("ws://localhost:8080/websocket"));
            WebSocketClient client = new WebSocketClient();
            session.getBasicRemote().sendText("客户端发送消息");
            client.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

登录后复制

以上就是使用Java和javax.websocket库实现WebSocket通信的示例代码。通过WebSocket，我们可以在服务器和客户端之间快速传递消息，实现实时通信的功能。使用WebSocket可以实时地推送数据到客户端，这在实时聊天、实时数据展示等应用场景非常有用。

以上就是Java开发：如何使用WebSocket进行实时通信的详细内容，更多请关注php中文网其它相关文章！