design draft: top-link, embedded connection management for c#/java/...

top-link.md

Server framework (via Jetty/Netty/or build-in)

• connector
• XXXconnection
• XXXchannel or upstram-pipeline for accept/receive
• XXXtransport or downstream-pipeline for send
• handler
• io buffer
• codedec
• server
• client

server.bind(8080);//using connector
server.setChannelSinkProviderOrPipelineFactory();//using websocket/tcp/http
server.setMessagHandler();
server.run();

Duplex Endpoint

endpoint1 <--> endpoint2

endpoint1 <-- endpointProxy1

endpointProxy2 --> endpoint2

Channel

• ServerChannel
  • WebSocketServerChannel
• ClientChannel
  • WebSocketClientChannel

clientChannel.send(byte[],offset,length);//send directly

connPool

• server-conn <——
• client-conn ——>

connPool.getConn(id);
connPool.getConn(identity);
connPool.getConn(uri);

IdentityMapping

connId<->identity

IdentityMapping.set(new CustomMappingHandlerWithAppKey());

for upper layer api usage.

Identity and Handshake

e1.id->e2 e2.id->e1

e1 got e2proxy.id e2 got e1proxy.id

duplex conn built.

UriMapping

identity -> uri

UriMapping.set(new CustomMappingHandlerWithZk());

heartbeat

necessary

• max idle 60s+
• do not ping

deploy

• Agent
• Embedded
  • same domain/classloader/..
  • isolated

---

upper layer

rpc protocol

message protocol

auth/verify

...