jssmpJava 版 SSMP 协议实现
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();
评论
SSMP开源消息传递协议
SSMP是Stupid-SimpleMessagingProtocol,开源消息传递协议。语法:message = ( request | response | event ) LFreque
SSMP开源消息传递协议
0
jgossipJava 版的 Gossip 协议实现
一个 Java 版的 Gossip 协议实现。Gossip 算法又被称为反熵(Anti-Entrop
jgossipJava 版的 Gossip 协议实现
0
jgossipJava 版的 Gossip 协议实现
一个Java版的Gossip协议实现。Gossip算法又被称为反熵(Anti-Entropy),熵是物理学上的一个概念,代表杂乱无章,而反熵就是在杂乱无章中寻求一致,这充分说明了Gossip的特点:在
jgossipJava 版的 Gossip 协议实现
0