Java 版 SSMP 协议实现：jssmp
jopen
9年前
jssmp 是 Java 版 SSMP 开源实现。
依赖：
-
JDK 1.8 or higher
-
netty 3.10+
-
slf4j 1.7+
-
guava 17+
客户端
// given: SSLEngine sslEngine; SSMPClient c = new SSMPClient("localhost", 1234, new HashedWheelTimer(), new NioClientSocketChannelFactory(), () -> new SslHandler(sslEngine), e -> System.out.println("event: " + e)); c.connect(SSMPIdentifier.fromInternal("foo"), SSMPIdentifier.fromInternal("secret"), "NotARealSecret", new ConnectionListener() { @Override public void connected() { System.out.println("connected"); } @Override public void disconnected() { System.out.println("disconnected"); } }); SSMPResponse r = c.request(SSMPRequest.ucast(SSMPIdentifier.fromInternal("bar"), "Hello World!")).get(); System.out.println("response: " + r);服务器端
// given: SSLEngine sslEngine; SSMPServer s = new SSMPServer(new InetSocketAddress("localhost", 1234), new HashedWheelTimer(), new NioServerSocketChannelFactory(), () -> new SslHandler(sslEngine), new Authenticator() { @Override public boolean authenticate(SSMPIdentifier id, SSMPIdentifier scheme, String cred) { return scheme.toString().equals("secret") && cred.equals("NotARealSecret"); } @Override public ChannelBuffer unauthorized() { return ChannelBuffers.wrappedBuffer("401 secret\n".getBytes(StandardCharsets.US_ASCII)); } }); s.start();