distkv-project / drpc Goto Github PK

Add the protocol concept for drpc: BY_DEFAULT and PROTOBUF.

In BY_DEFAULT protocol, we support users to invoke the remote service as a local method by default.

@zhengrenjie @MrKingHH @senyer @kairbon Any future thoughts on this?

Dependencies:

• handy: as event and networking library
• protobuf: serilization

Support sync and async client.

The related feature is #52

@senyer

Add a compile tool of drpc to generate a java file from the following proto file.

# proto file
service DstDictService {
    rpc put(PutRequest) returns (PutResponse);
}

the auto-generated java file:

// java file
/// Auto-generated file by drpcc
package com.distkv.dst.rpc.service;

import com.distkv.dst.rpc.protobuf.generated.CommonProtocol;
import com.distkv.dst.rpc.protobuf.generated.ListProtocol;
import java.util.concurrent.CompletableFuture;

public interface DstListService {

  CompletableFuture<ListProtocol.PutResponse> put(ListProtocol.PutRequest request);

}

And note that we can use antlr4 to write the parser of drpcc

In some cases, the users should maintain the thread model of their apps, so we should provide a options to enable io_threads only.

The option of this could be named enableIOThreadsOnly, and it should be disabled by default.

@zhengrenjie @MrKingHH @senyer @kairbon cc

Description of method should not care args anymore. A ServerName and MethodName pair could determine which method should be invoked.
Method description map should be established when server has been registered.

We shouldn't expose NettyClient in APIs.

Better to wrap it with DousiClient.

Fix exporter in server, make exporter be continuous.

Question:
For example: a: //127.0.0.1: 8082 and b: //127.0.0.1: 8082 can successfully establish a connection.

It is unreasonable that a request can be established for any protocol. The agreement should be judged. If the agreement is incorrect, the corresponding prompt information of the user should be returned.

@MrKingHH @zhengrenjie @senyer @tortuo @kairbon @shutingting @LCM1999

@jovany-wang

add dousi client module

Fix reference in protoctol model, make reference can be continuous.

LongAdder#sum
LongAdder#longValue
Methods above here is not concurrent-safe.

@jovany-wang

Remove class URL and replace with a more comprehensible class.

@tortuo