WebSocket实践

1. WebSocket是什么

WebSocket 是一种与 HTTP 不同的协议。两者都位于 OSI 模型的应用层，并且都依赖于传输层的 TCP 协议。 虽然它们不同，但 RFC 6455 规定：WebSocket设计为通过 80 和 443 端口工作，以及支持HTTP代理和中介，从而使其与HTTP协议兼容。为了实现兼容性， WebSocket 握手使用 HTTP Upgrade 头从 HTTP 协议更改为 WebSocket 协议。

与HTTP不同，WebSocket 提供全双工通信。此外，WebSocket 还可以在 TCP 之上启用消息流。 TCP 单独处理字节流，没有固有的消息概念。

2. WebSocket、HTTP长连接区别

HTTP长连接的本质还是HTTP协议，工作模式依旧是一问一答。即：客户端发起一次请求，服务器回应最多一次响应。这个本质并没有得到改变，改变的只是在同一个TCP连接上可以进行多次请求和多次响应。Websocket不一样，客户端可以只请求一次服务器，然后服务器返回多次响应。即：当连接建立之后，服务器可以主动给客户端发送信息，这点是HTTP做不到的。

3. WebSocket实践（Java）

3.1 服务端

使用IDEA创建maven工程WebSocket_S

WebSocket_S.png

引入websocket依赖

<dependency>
    <groupId>org.java-websocket</groupId>
    <artifactId>Java-WebSocket</artifactId>
    <version>1.5.6</version>
</dependency>

编写SocketServer.Java

package com.devpotato;

import org.java_websocket.WebSocket;
import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.server.WebSocketServer;

import java.net.InetSocketAddress;

public class SocketServer extends WebSocketServer {

    public SocketServer(int port) {
        super(new InetSocketAddress(port));
    }

    public void onOpen(WebSocket webSocket, ClientHandshake clientHandshake) {
        System.out.println("收到新的WebSocket连接请求: " + webSocket.getRemoteSocketAddress().getAddress().getHostAddress());

        // 给新的WebSocket Client发送一条消息
        webSocket.send("Welcome to the server!");

        // 给所有的Client发送一条消息
        broadcast("new connection: " + clientHandshake.getResourceDescriptor());
    }

    public void onClose(WebSocket webSocket, int i, String s, boolean b) {
        System.out.println("--- onClose" + webSocket + s);

        broadcast(webSocket + " onClose!");
    }

    public void onMessage(WebSocket webSocket, String s) {
        System.out.println("--- onMessage: " + webSocket + ": " + s);

        broadcast(s);
    }

    public void onError(WebSocket webSocket, Exception e) {
        System.out.println("--- onError: " + webSocket + ": " + e.getMessage());
    }

    public void onStart() {
        System.out.println("Server started!");
    }
}

编写App.Java

public class App {
    public static void main(String[] args) {
        System.out.println("Hello World!");

        SocketServer socketServer = new SocketServer(8080);
        socketServer.start();
    }
}

3.2 客户端

使用IDEA创建maven工程WebSocket_C

WebSocket_C.png

引入websocket依赖

<dependency>
    <groupId>org.java-websocket</groupId>
    <artifactId>Java-WebSocket</artifactId>
    <version>1.5.6</version>
</dependency>

编写App.Java

package com.devpotato;

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
import java.net.URI;

public class App {
    public static void main(String[] args) throws Exception {
        System.out.println("Hello World!");

        WebSocketClient webSocketClient = new WebSocketClient(new URI("ws://127.0.0.1:8080")) {
            public void onOpen(ServerHandshake serverHandshake) {
                System.out.println("--- onOpen ---");
            }

            public void onMessage(String s) {
                System.out.println("--- onMessage: " + s);
            }

            public void onClose(int i, String s, boolean b) {
                System.out.println("--- onClose: " + s);
            }

            public void onError(Exception e) {
                System.out.println("--- onError: " + e.getMessage());
            }
        };

        webSocketClient.connect();

        // 往websocket服务端发送数据
        webSocketClient.send("Hello, this is client!");
    }
}

4、启动服务

启动服务端

Server started!

启动客户端

Server started!
收到新的WebSocket连接请求: 127.0.0.1

--- onOpen ---
--- onMessage: Welcome to the server!
--- onMessage: new connection: /