javascript
socket.io服务端是java_SpringBoot(23) 集成socket.io服务端和客户端实现通信
@Slf4j
@Service(value = "socketIOService")
public class SocketIOServiceImpl implements ISocketIOService {
/**
* 存放已連接的客戶端
*/
private static Map clientMap = new ConcurrentHashMap<>();
/**
* 自定義事件`push_data_event`,用于服務(wù)端與客戶端通信
*/
private static final String PUSH_DATA_EVENT = "push_data_event";
@Autowired
private SocketIOServer socketIOServer;
/**
* Spring IoC容器創(chuàng)建之后，在加載SocketIOServiceImpl Bean之后啟動(dòng)
*/
@PostConstruct
private void autoStartup() {
start();
}
/**
* Spring IoC容器在銷毀SocketIOServiceImpl Bean之前關(guān)閉,避免重啟項(xiàng)目服務(wù)端口占用問(wèn)題
*/
@PreDestroy
private void autoStop() {
stop();
}
@Override
public void start() {
// 監(jiān)聽(tīng)客戶端連接
socketIOServer.addConnectListener(client -> {
log.debug("************ 客戶端： " + getIpByClient(client) + " 已連接 ************");
// 自定義事件`connected` -> 與客戶端通信 (也可以使用內(nèi)置事件，如：Socket.EVENT_CONNECT)
client.sendEvent("connected", "你成功連接上了哦...");
String userId = getParamsByClient(client);
if (userId != null) {
clientMap.put(userId, client);
}
});
// 監(jiān)聽(tīng)客戶端斷開(kāi)連接
socketIOServer.addDisconnectListener(client -> {
String clientIp = getIpByClient(client);
log.debug(clientIp + " *********************** " + "客戶端已斷開(kāi)連接");
String userId = getParamsByClient(client);
if (userId != null) {
clientMap.remove(userId);
client.disconnect();
}
});
// 自定義事件`client_info_event` -> 監(jiān)聽(tīng)客戶端消息
socketIOServer.addEventListener(PUSH_DATA_EVENT, String.class, (client, data, ackSender) -> {
// 客戶端推送`client_info_event`事件時(shí)，onData接受數(shù)據(jù)，這里是string類型的json數(shù)據(jù)，還可以為Byte[],object其他類型
String clientIp = getIpByClient(client);
log.debug(clientIp + " ************ 客戶端：" + data);
});
// 啟動(dòng)服務(wù)
socketIOServer.start();
// broadcast: 默認(rèn)是向所有的socket連接進(jìn)行廣播，但是不包括發(fā)送者自身，如果自己也打算接收消息的話，需要給自己?jiǎn)为?dú)發(fā)送。
new Thread(() -> {
int i = 0;
while (true) {
try {
// 每3秒發(fā)送一次廣播消息
Thread.sleep(3000);
socketIOServer.getBroadcastOperations().sendEvent("myBroadcast", "廣播消息 " + DateUtil.now());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}).start();
}
@Override
public void stop() {
if (socketIOServer != null) {
socketIOServer.stop();
socketIOServer = null;
}
}
@Override
public void pushMessageToUser(String userId, String msgContent) {
SocketIOClient client = clientMap.get(userId);
if (client != null) {
client.sendEvent(PUSH_DATA_EVENT, msgContent);
}
}
/**
* 獲取客戶端url中的userId參數(shù)(這里根據(jù)個(gè)人需求和客戶端對(duì)應(yīng)修改即可)
*
* @param client: 客戶端
* @return: java.lang.String
*/
private String getParamsByClient(SocketIOClient client) {
// 獲取客戶端url參數(shù)(這里的userId是唯一標(biāo)識(shí))
Map> params = client.getHandshakeData().getUrlParams();
List userIdList = params.get("userId");
if (!CollectionUtils.isEmpty(userIdList)) {
return userIdList.get(0);
}
return null;
}
/**
* 獲取連接的客戶端ip地址
*
* @param client: 客戶端
* @return: java.lang.String
*/
private String getIpByClient(SocketIOClient client) {
String sa = client.getRemoteAddress().toString();
String clientIp = sa.substring(1, sa.indexOf(":"));
return clientIp;
}
}
總結(jié)
以上是生活随笔為你收集整理的socket.io服务端是java_SpringBoot(23) 集成socket.io服务端和客户端实现通信的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： java ecc 加密_java-信息安
- 下一篇： java实体中文字段_java - Sp