mpush-client-java

mpush-client-java copied to clipboard

1. bug之处 @Override public Future push(PushContext context) { if (!connection.getSessionContext().handshakeOk()) { logger.warn("connection is not handshake ok!"); return null; } PushMessage message = new PushMessage(context.getContext(), connection); message.addFlag(context.ackModel.flag); message.send(); logger.debug("

csoftware

1. bug所在 @Override public void run() { queue.remove(sessionId); timeout(); } 2. bug的修复 @Override public void run() { RequestTask requestTask = queue.remove(sessionId); if (requestTask != null) { timeout(); } }

csoftware

public static void main(String[] args) throws Exception { int count = 1; String serverHost = "127.0.0.1"; int sleep = 1000; if (args != null && args.length > 0) { count...

hotsmile

liujiaxian

是tcp协议还是mqtt协议？还是自己实现的一套协议

mattxzhang