@Slf4j

@Service(value = "socketIOService")

public class SocketIOServiceImpl implements ISocketIOService {

/**

* 存放已連接的客戶端

*/

private static Map clientMap = new ConcurrentHashMap<>();

/**

* 自定義事件`push_data_event`,用于服務端與客戶端通信

*/

private static final String PUSH_DATA_EVENT = "push_data_event";

@Autowired

private SocketIOServer socketIOServer;

/**

* Spring IoC容器創建之后，在加載SocketIOServiceImpl Bean之后啟動

*/

@PostConstruct

private void autoStartup() {

start();

}

/**

* Spring IoC容器在銷毀SocketIOServiceImpl Bean之前關閉,避免重啟項目服務端口占用問題

*/

@PreDestroy

private void autoStop() {

stop();

}

@Override

public void start() {

// 監聽客戶端連接

socketIOServer.addConnectListener(client -> {

log.debug("************ 客戶端： " + getIpByClient(client) + " 已連接 ************");

// 自定義事件`connected` -> 與客戶端通信 (也可以使用內置事件，如：Socket.EVENT_CONNECT)

client.sendEvent("connected", "你成功連接上了哦...");

String userId = getParamsByClient(client);

if (userId != null) {

clientMap.put(userId, client);

}

});

// 監聽客戶端斷開連接

socketIOServer.addDisconnectListener(client -> {

String clientIp = getIpByClient(client);

log.debug(clientIp + " *********************** " + "客戶端已斷開連接");

String userId = getParamsByClient(client);

if (userId != null) {

clientMap.remove(userId);

client.disconnect();

}

});

// 自定義事件`client_info_event` -> 監聽客戶端消息

socketIOServer.addEventListener(PUSH_DATA_EVENT, String.class, (client, data, ackSender) -> {

// 客戶端推送`client_info_event`事件時，onData接受數據，這里是string類型的json數據，還可以為Byte[],object其他類型

String clientIp = getIpByClient(client);

log.debug(clientIp + " ************ 客戶端：" + data);

});

// 啟動服務

socketIOServer.start();

// broadcast: 默認是向所有的socket連接進行廣播，但是不包括發送者自身，如果自己也打算接收消息的話，需要給自己單獨發送。

new Thread(() -> {

int i = 0;

while (true) {

try {

// 每3秒發送一次廣播消息

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參數(這里根據個人需求和客戶端對應修改即可)

*

* @param client: 客戶端

* @return: java.lang.String

*/

private String getParamsByClient(SocketIOClient client) {

// 獲取客戶端url參數(這里的userId是唯一標識)

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;

}

}

總結

以上是生活随笔為你收集整理的socket.io服务端是java_SpringBoot(23) 集成socket.io服务端和客户端实现通信的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。