English | 简体ä¸æ–‡
A WebSocket framework
<dependency>
<groupId>cool.scx</groupId>
<artifactId>scx-socket</artifactId>
<version>{version}</version>
</dependency>
import cool.scx.socket.ScxSocketServer;
import io.vertx.core.Vertx;
public class YourServer {
public static void main(String[] args) {
//1, Create Server
var scxSocketServer = new ScxSocketServer();
//2, Add ClientConnect Event
scxSocketServer.onConnect(serverSocket -> {
serverSocket.send("Hello ScxSocketClient !!!");
serverSocket.onMessage((m) -> {
System.out.println("onMessage : " + m);
});
serverSocket.onClose(c -> {
System.out.println("onClose");
});
serverSocket.onError(e -> {
System.out.println("onError");
});
});
//3, Using vertx httpServer call
Vertx.vertx().createHttpServer()
.webSocketHandler(scxSocketServer::call)
.listen(8990);
}
}
import cool.scx.socket.ScxSocketClient;
import io.vertx.core.Vertx;
public class YourClient {
public static void main(String[] args) {
var vertxWebSocketClient = Vertx.vertx().createWebSocketClient();
//1, Create Client
var scxSocketClient = new ScxSocketClient("ws://127.0.0.1:8990", vertxWebSocketClient);
//2, Add Event
scxSocketClient.onConnect(clientSocket -> {
clientSocket.send("Hello ScxSocketServer !!!");
clientSocket.onMessage((m) -> {
System.out.println("onMessage : " + m);
});
clientSocket.onClose(c -> {
System.out.println("onClose");
});
clientSocket.onError(e -> {
System.out.println("onError");
});
});
//3, Connect Server
scxSocketClient.connect();
}
}
onMessage : Hello ScxSocketServer !!!
onMessage : Hello ScxSocketClient !!!
For more information, see docs
Note : Implementation of JavaScript, see SCX-SOCKET-JS