代码示例

步骤1

今天使用Java客户端调用Websocket服务端
以下是客户端代码：

import com.sinosoft.springbootplus.lft.business.dispatch.map.application.service.impl.LawEnforceSosServiceImpl;
import com.sinosoft.springbootplus.lft.business.dispatch.map.dto.LawEnforceSosAddDto;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;
import org.jsoup.select.Elements;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import javax.websocket.*;
import java.nio.ByteBuffer;
import java.text.ParseException;
import java.text.SimpleDateFormat;@ClientEndpoint
@Component
@Slf4j
public class WebSocketClient {private static LawEnforceSosServiceImpl lawEnforceSosService;@Autowiredpublic void setLawEnforceSosServiceImpl(LawEnforceSosServiceImpl enforceSosService) {lawEnforceSosService = enforceSosService;}@OnOpenpublic void onOpen(Session session) {System.out.println("Connected to server");log.info("websocket链接打开!Connected to server");try {String message = "你好";// Send a text message to the serversession.getBasicRemote().sendText(message);} catch (Exception e) {e.printStackTrace();}}@OnMessagepublic void onMessage(String message) throws ParseException {log.info("收到的消息");}@OnMessagepublic void binaryMessage(Session session, ByteBuffer msg) {log.info("收到的消息");}@OnMessagepublic void pongMessage(Session session, PongMessage msg) {log.info("收到的消息");}@OnClosepublic void onClose() {log.info("websocket链接关闭!Close to server");}// ...
}

步骤2

在项目启动时，开启Websocket服务

import com.sinosoft.springbootplus.lft.business.dispatch.map.common.WebSocketClient;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;import javax.websocket.ContainerProvider;
import javax.websocket.WebSocketContainer;
import java.net.URI;/*** @Author mc* @Date 2024/01/29* @Version 1.0*/@Component
@Slf4j
public class MyDeviceLineRunner implements CommandLineRunner {@Overridepublic void run(String... args){new Thread(() -> {log.info("开始===调用websocket接口");try {WebSocketContainer webSocketContainer = ContainerProvider.getWebSocketContainer();URI uri = null;uri = new URI("这里是地址！");webSocketContainer.connectToServer(WebSocketClient.class, uri);} catch (Exception e) {e.printStackTrace();}});.start();}
}