在Java中发送WebSocket请求,可以使用Java的WebSocket客户端库,比如 Tyrus、Jetty等。下面是一个使用Tyrus发送WebSocket请求的示例代码:
import javax.websocket.ClientEndpoint; import javax.websocket.ContainerProvider; import javax.websocket.OnMessage; import javax.websocket.Session; import javax.websocket.WebSocketContainer; import java.net.URI; @ClientEndpoint public class WebSocketClient { @OnMessage public void onMessage(String message) { System.out.println("Received message: " + message); } public static void main(String[] args) { WebSocketContainer container = ContainerProvider.getWebSocketContainer(); try { Session session = container.connectToServer(WebSocketClient.class, new URI("ws://localhost:8080/websocket")); session.getBasicRemote().sendText("Hello, WebSocket Server!"); session.close(); } catch (Exception e) { e.printStackTrace(); } } }
上面的代码通过使用Tyrus库中的WebSocketContainer
类来建立WebSocket连接,并通过connectToServer()
方法传递WebSocket客户端类和WebSocket服务器的URI来连接到WebSocket服务器。在onMessage()
方法中定义了接收消息的处理逻辑,在main()
方法中通过session.getBasicRemote().sendText()
方法发送文本消息到WebSocket服务器,并通过session.close()
方法关闭会话。
请注意,上述示例代码中的WebSocket服务器URI是ws://localhost:8080/websocket
,你需要根据实际情况修改为你的WebSocket服务器的URI。