在Java中,可以使用socket.io-client
库来发送和接收消息。
首先,需要在项目中添加socket.io-client
库的依赖。可以在pom.xml
中添加以下代码:
io.socket socket.io-client 1.0.0
然后,可以使用以下代码来发送和接收消息:
import io.socket.client.IO; import io.socket.client.Socket; import io.socket.emitter.Emitter; import java.net.URISyntaxException; public class SocketIOClient { public static void main(String[] args) { try { // 创建Socket连接 Socket socket = IO.socket("http://localhost:3000"); // 监听连接成功事件 socket.on(Socket.EVENT_CONNECT, new Emitter.Listener() { @Override public void call(Object... args) { System.out.println("Connected to server"); } }); // 监听消息事件 socket.on("message", new Emitter.Listener() { @Override public void call(Object... args) { String message = (String) args[0]; System.out.println("Received message: " + message); } }); // 连接到服务器 socket.connect(); // 发送消息 socket.emit("message", "Hello from Java"); } catch (URISyntaxException e) { e.printStackTrace(); } } }
在以上代码中,首先创建了一个Socket
对象,并连接到指定的URL。然后监听连接成功事件和消息事件,并在事件发生时进行相应的处理。最后使用emit
方法发送消息到服务器。