java WebSocket 服务端代码
程序员文章站
2024-03-21 12:45:04
...
ackage org.fh.plugins.ChatServer; import java.net.InetSocketAddress; import java.net.UnknownHostException; import org.java_websocket.WebSocket; import org.java_websocket.framing.Framedata; import org.java_websocket.handshake.ClientHandshake; import org.java_websocket.server.WebSocketServer; /** * 说明:websocket服务端 * 作者:FH Admin * from:fhadmin.cn */ public class ChatServer extends WebSocketServer{ public BulletChatServer(int port) throws UnknownHostException { super(new InetSocketAddress(port)); } public BulletChatServer(InetSocketAddress address) { super(address); } /** * 客户端发送消息到服务器时触发事件 */ @Override public void onMessage(WebSocket conn, String message){ message = message.toString(); if(null != message && message.startsWith("[video313596790]")){ this.userjoin(message.replaceFirst("\\[video313596790\\]", ""),conn); }else{ BulletChatServerPlool.sendMessage(message.toString());//向所有在线用户发送消息 } } public void onFragment( WebSocket conn, Framedata fragment ) { } /** * 用户加入处理 * @param user */ public void userjoin(String user, WebSocket conn){ BulletChatServerPlool.addUser(user,conn); //向连接池添加当前的连接对象 } /** * 用户下线处理 * @param user */ public void userLeave(WebSocket conn){ BulletChatServerPlool.removeUser(conn); //在连接池中移除连接 } /** * 触发连接事件 */ @Override public void onOpen( WebSocket conn, ClientHandshake handshake ) {} /** * 触发关闭事件 */ @Override public void onClose( WebSocket conn, int code, String reason, boolean remote ) { userLeave(conn); } /** * 触发异常事件 */ @Override public void onError( WebSocket conn, Exception ex ) { if( conn != null ) {} } @Override public void onStart() {} }
推荐阅读
-
java WebSocket 服务端代码
-
完整java开发中JDBC连接数据库代码和步骤 博客分类: JDBC jdbc
-
为什么不允许代码里出现“魔数” 博客分类: Java java
-
java代码优化提点 博客分类: javaweb
-
多双慧眼看代码漏洞 BlazeDS FlexClient.java 博客分类: 编程基础
-
Java编程的动态特性,使用BCEL代码生成工具,极大简化Class Transformation开发 Java字节码虚拟机BCELClassTransformer
-
Java的Excl表格的导出功能(代码全)
-
Java代码实现Excel表格导出
-
Mysql:Java代码实现MySQL数据库导出
-
Java代码实现excel的导入和导出