- 根据netty的websoctet实现单聊
这里在传输的数据格式用文本转JSON的@Override protected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) throws Exception { // (1) ObjectMapper mapper = new ObjectMapper(); Message message = mapper.readValue(msg.text(), Message.class); Channel incoming = ctx.channel(); if(null!=message) { if(ChatType.BIND.equals(message.getCmd())){//绑定上线 ChannelManager.addChannel(message.getFrom(), incoming); }else if(ChatType.LEAVE.equals(message.getCmd())) { ChannelManager.removeChannelByCode(message.getFrom()); }else if(ChatType.SINGLE.equals(message.getCmd())) { message.setMsg(HtmlUtils.htmlEscape(message.getMsg())); if(null!=ChannelManager.getChannel(message.getAccept())) { ChannelManager.getChannel(message.getAccept()).writeAndFlush(new TextWebSocketFrame(mapper.writeValueAsString(message))); }else { String from=message.getFrom(); message.setFrom(message.getAccept()); message.setAccept(from); message.setMsg("["+message.getFrom()+"]未上线"); incoming.writeAndFlush(new TextWebSocketFrame(mapper.writeValueAsString(message))); } }else if(ChatType.GROUP.equals(message.getCmd())) { message.setMsg(HtmlUtils.htmlEscape(message.getMsg())); }else { System.out.println("未识别的命令"); } } } - 简单的数据格式
private String cmd;//1.绑定上线 2.下线 3.单聊 4.群聊 private String from;//用户ID private String accept;//接受ID private String group;//组ID private String msg;//文本信息
- 效果
