[GitHub] [dubbo-samples] zxrneu opened a new issue, #587: How to set the number of connections?

[GitBox]

zxrneu opened a new issue, #587:
URL: https://github.com/apache/dubbo-samples/issues/587

   
   **### Question：reference.setConnections(10);//设置未生效**
   <img width="941" alt="image" 
src="https://user-images.githubusercontent.com/42803787/203700154-ece52c62-c20b-4827-8937-edcd433e54d0.png";>
   
   **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();
   
       }
   }
   ```
   
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: notifications-unsubscr...@dubbo.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@dubbo.apache.org
For additional commands, e-mail: notifications-h...@dubbo.apache.org