使用org.java_websocket库第三方库实现广播
库来实现WebSocket服务器,并通过。
可以使用org.java_websocket库来实现WebSocket服务器,并通过broadcast方法实现广播
java实现
import org.java_websocket.WebSocket;
import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.server.WebSocketServer;
import java.net.InetSocketAddress;
import java.io.IOException;
public class BroadcastWebSocketServer extends WebSocketServer {
public BroadcastWebSocketServer(int port) throws IOException {
super(new InetSocketAddress(port));
}
@Override
public void onOpen(WebSocket conn, ClientHandshake handshake) {
conn.send("Welcome to the server!");
broadcast("New connection: " + handshake.getResourceDescriptor());
}
@Override
public void onClose(WebSocket conn, int code, String reason, boolean remote) {
broadcast(conn.getRemoteSocketAddress().getAddress().getHostAddress() + " has left the room!");
}
@Override
public void onMessage(WebSocket conn, String message) {
broadcast("Message from " + conn.getRemoteSocketAddress().getAddress().getHostAddress() + ": " + message);
}
@Override
public void onError(WebSocket conn, Exception ex) {
ex.printStackTrace();
}
@Override
public void onStart() {
System.out.println("Server started!");
}
}
火山引擎开发者社区是火山引擎打造的AI技术生态平台,聚焦Agent与大模型开发,提供豆包系列模型(图像/视频/视觉)、智能分析与会话工具,并配套评测集、动手实验室及行业案例库。社区通过技术沙龙、挑战赛等活动促进开发者成长,新用户可领50万Tokens权益,助力构建智能应用。
更多推荐
所有评论(0)