<dependency>
    <groupId>com.github.tohodog</groupId>
    <artifactId>qsrpc</artifactId>
    <version>1.3.0</version>
</dependency>

#nacos
qsrpc.nacos.addr=192.168.0.100:8848
#qsrpc.nacos.srvname=qsrpc

#zookeeper
#qsrpc.zk.ips=127.0.0.1:2181
#qsrpc.zk.path=/qsrpc

#node server
qsrpc.node.ip=127.0.0.1
qsrpc.node.port=19980
qsrpc.node.action=user,order
#qsrpc.node.weight=1
#qsrpc.node.zip=snappy/gzip
#qsrpc.connect.timeout=60000

    //open node server 1 (read application.properties)
    NodeInfo nodeInfo = NodeRegistry.buildNode();
    //sync callback
    NodeLauncher.start(nodeInfo, new MessageListener() {
        @Override
        public byte[] onMessage(Async async, byte[] message) {
        return ("Hello! node1 callback -" + new String(message)).getBytes();
        }
    });


    // open node server 2
    ServerConfig.RPC_CONFIG.setNacosAddr("192.168.0.100:8848");
    ServerConfig.RPC_CONFIG.setNacosServiceName("qsrpc");
    // ServerConfig.RPC_CONFIG.setZkIps("127.0.0.1:2181");
    // ServerConfig.RPC_CONFIG.setZkPath("/qsrpc");
    NodeInfo nodeInfo2 = new NodeInfo();
    nodeInfo2.setAction("order");//node server action
    nodeInfo2.setIp("127.0.0.1");//node server ip
    nodeInfo2.setPort(8848);//nodeserver port
    nodeInfo2.setWeight(2);//request weight

    //async callback
    NodeLauncher.start(nodeInfo2, new MessageListener() {
        @Override
        public byte[] onMessage(final Async async, final byte[] message) {
        new Thread(new Runnable() {
            @Override
            public void run() {
            async.callBack(("Hello! node2 callback -" + new String(message)).getBytes());
            }
        }).start();
        return null;
        }
    });

    //async
    for (int i = 0; i < 9; i++) {
        //Send byte[] based on action
        RPCClientManager.getInstance().sendAsync("user", "user".getBytes(),
            new Callback<byte[]>() {
            @Override
            public void handleResult(byte[] result) {
                System.out.println("send [user] Result: " + new String(result));
            }

            @Override
            public void handleError(Throwable error) {
                error.printStackTrace();
            }
            });
    }
    System.out.println("send [user] Done");

    //sync
    for (int i = 0; i < 9; i++) {
        Thread.sleep(1000);
        byte[] msg_cb = RPCClientManager.getInstance().sendSync("order", "order".getBytes());
        System.out.println("send [order] Result: " + new String(msg_cb));
    }
    System.out.println("send [order] Done");

    //future
    CallFuture<byte[]> callFuture = RPCClientManager.getInstance().sendAsync("user", "user".getBytes());
    System.out.println("send [user] FutureResult: " + new String(callFuture.get()));