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: /
