pom.xml
<dependency>
<groupId>org.java-websocket</groupId>
<artifactId>Java-WebSocket</artifactId>
<version>1.3.4</version>
</dependency>
SimpleWebSocketServer.java
package com.geostar.gfstack.operationcenter.common.util; import com.geostar.gfstack.framework.log.common.GeoLogger;
import com.geostar.gfstack.operationcenter.common.properties.ConfigGeoStar;
import org.java_websocket.WebSocket;
import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.server.WebSocketServer; import java.net.InetSocketAddress;
import java.net.UnknownHostException;
import java.util.Collection; public class SimpleWebSocketServer extends WebSocketServer { private static GeoLogger logger = GeoLogger.getLogger(SimpleWebSocketServer.class); private static SimpleWebSocketServer instance; public static final Integer port = ConfigGeoStar.getWebSocketPort(); @Override
public void onOpen(WebSocket conn, ClientHandshake handshake) {
logger.info("Server open!");
} @Override
public void onClose(WebSocket conn, int code, String reason, boolean remote) {
logger.info("Server closed!");
} @Override
public void onMessage(WebSocket conn, String message) {
this.sendToAll(message);
} @Override
public void onError(WebSocket conn, Exception e) {
logger.error(e.getMessage(), e);
} @Override
public void onStart() {
logger.info("Server started!");
} public void sendToAll(String text) {
Collection<WebSocket> con = connections();
synchronized (con) {
for (WebSocket c : con) {
c.send(text);
}
}
} private SimpleWebSocketServer() {
super();
try {
SimpleWebSocketServer s = new SimpleWebSocketServer(port);
s.start();
} catch (UnknownHostException e) {
e.printStackTrace();
}
} private SimpleWebSocketServer(int port) throws UnknownHostException {
super(new InetSocketAddress(port));
} public synchronized static SimpleWebSocketServer getInstance() {
if (instance == null) {
instance = new SimpleWebSocketServer();
}
return instance;
} }
SimpleWebSocketClient.java
package com.geostar.gfstack.operationcenter.common.util; import com.geostar.gfstack.framework.log.common.GeoLogger;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.drafts.Draft;
import org.java_websocket.handshake.ServerHandshake; import java.net.URI; public class SimpleWebSocketClient extends WebSocketClient { private static GeoLogger logger = GeoLogger.getLogger(SimpleWebSocketClient.class); public SimpleWebSocketClient(URI serverUri, Draft protocolDraft) {
super(serverUri, protocolDraft);
} @Override
public void onOpen(ServerHandshake serverHandshake) {
logger.info("Client open!");
} @Override
public void onMessage(String s) {
logger.info("Client message:"+s);
} @Override
public void onClose(int i, String s, boolean b) {
logger.info("Client onClose!");
} @Override
public void onError(Exception e) {
logger.error(e.getMessage(), e);
} }
前端js用法：
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Title</title>
<script type="text/javascript" src="../staticresource/fe-lib/websocket/web_socket.js"></script> <script type="text/javascript"> // Write your code in the same way as for native WebSocket:
var ws = new WebSocket('ws://192.168.30.174:8887')
ws.onopen = function() {
console.log('open')
ws.send('Hello') // Sends a message.
}
ws.onmessage = function(e) {
// Receives a message.
console.log(e.data);
}
ws.onclose = function() {
console.log('close')
} </script>
</head>
<body> </body>
</html>
java客户端用法：
SimpleWebSocketServer.getInstance();
URI uri = null;
WebSocketClient client = null;
try {
uri = new URI("ws://localhost:" + SimpleWebSocketServer.port);
} catch (URISyntaxException e) {
e.printStackTrace();
}
if(uri != null){
client = new SimpleWebSocketClient(uri, new Draft_6455());
client.connect();
}
if(client != null){
client.send("hello java");
}