Wechat applet customer service access to send and receive messages

The company has many small programs and customer service functions , Realize unified access to chat

The notification address of each applet notification access is different , But the logic of the access process is the same , Identify the applet when accessing  

netty Send a message to the page uniformly websocket part , Define the message body required by your business

@Component
public class ChannelWechatNotice {

	private static final Logger lg = LoggerFactory.getLogger(ChannelWechatNotice.class);

	/**socketWxchat.put("message", JzWxchat);
	 * socketWxchat.put("type", "weixin");
	 * @param socketWxchat
	 */
	@Async
	public void postSocketUser(Map<String,Object> socketWxchat) {
		String jsonMsg=JsonUtil.getJsonLocalDataTime(socketWxchat);
//		String jsonMsg=JSONUtils.toJSONString(socketWxchat);
		lg.info(" call netty Send a message message ：" + jsonMsg);
		
		try {
			//  Send... To the specified user 
//			ChannelUser channelUser = ChannelConst.getChannelUser("1512312");
//			if(channelUser==null) {
//			lg.info(" Wechat notification call netty Send a message to userId：" + null);
//				return;
//			}

			//  Send to all online users 
			Map<String, ChannelUser> channelMap = ChannelConst.channelMap;
			for (Entry<String, ChannelUser> s : channelMap.entrySet()) {
				Channel channel = s.getValue().getChannel();
				channel.writeAndFlush(new TextWebSocketFrame(jsonMsg));
			}

		} catch (Exception e) {
			e.printStackTrace();
		}
	}

netty Integration part ,

public class ChatHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> {

	private static final Logger logger = LoggerFactory.getLogger(ChatHandler.class);
	
	/**
	 *  Broadcast to get messages 
	 */
	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {

		if (null != msg && msg instanceof FullHttpRequest) {
			//  You have to come here for the first time , Think the link here is successful 

			FullHttpRequest request = (FullHttpRequest) msg;
			String uri = request.uri();

			Map paramMap = getUrlParams(uri);
			//  Identification and sysuser Do the processing 
			System.out.println("channelRead The parameters of the receiving connection are ：" + JsonUtil.getJson(paramMap));
			if (uri.contains("?")&&paramMap.containsKey(ChannelConst.CONST_USERID)) {
				String userId = paramMap.get(ChannelConst.CONST_USERID).toString();
				String channelShortId = getChannelShortId(ctx);
				ChannelUser cu = new ChannelUser(channelShortId, userId, ctx.channel());
				ChannelConst.channelMap.put(userId, cu);
				System.err.println(" Identification succeeded , client channelMap Number ：" + ChannelConst.clients.size()); 
			}else { 
				ctx.close();// Don't let him connect 
				System.err.println(" Remove the abnormal connection ===========================================");
				return ;
			}
			
			String newUri = uri.substring(0, uri.indexOf("?"));
			request.setUri(newUri);
		 
		}   
		
		if(msg instanceof TextWebSocketFrame) {
			TextWebSocketFrame frame = (TextWebSocketFrame) msg;
			System.out.println(" Received a message from the client ：" + frame.text());

			//  Send the received message to all clients 
			for (Channel channel : ChannelConst.clients) {
				//  Pay attention to all websocket All data should be in the form of TextWebSocketFrame encapsulate 
				channel.writeAndFlush(
						new TextWebSocketFrame(" Messages received by the server ：" + LocalDateTime.now() + ", The news is ：" + frame.text()));
			}
		}
		
		
//		if(msg instanceof CloseWebSocketFrame) {
//			logger.info(" There are users who have exited ===========================================");
//		}else {
//			logger.info(" There's other news ===========================================");
//		}


		super.channelRead(ctx, msg);
	}

  High imitation wechat interface , You can send pictures or text , Different customers are connected to chat by different customer service