apache/dubbo

How to set the number of connections?

Open

#11,010 创建于 2022年11月24日

在 GitHub 查看
 (4 评论) (0 反应) (0 负责人)Java (26,453 fork)batch import
component/sdkhelp wantedtype/proposal

仓库指标

Star
 (41,524 star)
PR 合并指标
 (平均合并 7天 14小时) (30 天内合并 20 个 PR)

描述

### Question:reference.setConnections(10);//设置未生效

There is only one connection. How do you make multiple connections

server

public class EchoServer {
    public static void main(String[] args) throws IOException {
        ServiceConfig<EchoService> service = new ServiceConfig<>();
        service.setInterface(EchoService.class);
        service.setRef(new EchoImpl());

        DubboBootstrap bootstrap = DubboBootstrap.getInstance();
        bootstrap.application(new ApplicationConfig("tri-stub-server"))
//               .registry(new RegistryConfig("multicast://127.0.0.1:2181"))
                .protocol(new ProtocolConfig(CommonConstants.TRIPLE, 3002))
                .service(service)
                .start();
        System.out.println("Dubbo triple stub server started");
        System.in.read();
    }
}

client

public class EchoClient {
    public static void main(String[] args) throws IOException {
        for (int i = 0; i < 3; i++) {
            new Thread(()->{
                DubboBootstrap bootstrap = DubboBootstrap.newInstance();
                System.out.println(bootstrap);
                ReferenceConfig<EchoService> ref = new ReferenceConfig<>();
                ref.setInterface(EchoService.class);
                ref.setProtocol(CommonConstants.TRIPLE);
                ref.setProxy(CommonConstants.NATIVE_STUB);
                ref.setTimeout(3000);
                ref.setUrl("tri://127.0.0.1:3002");
                ref.setConnections(10);//设置未生效
                bootstrap.application(new ApplicationConfig("tri-stub-client"))
                        .reference(ref)
                        .start();

                EchoService echoService = ref.get();
//                Scanner sc = new Scanner(System.in);
                while (true){
//                    String input = sc.next();
                    EchoRequest request = EchoRequest.newBuilder().setMessage("input").build();
                    EchoResponse echoResponse = echoService.echo(request);
                    System.out.println("Received reply:" + echoResponse.getMessage());
                }
            }).start();
        }
        System.in.read();

    }
}

贡献者指南