Myrpc version 6

RPC The concept of

Background knowledge

• RPC Basic concepts of , Core functions

common RPC frame

Duboo Basic function

1. Telematics
2. Transparent remote procedure call based on interface method
3. Load balancing
4. Service registry

RPC The process

client Call the remote method -> request serialize -> Protocol code -> Network transmission -> Server side -> Deserialization request -> Call the local method to get response -> serialize -> code ->……

---

Version iteration process

Catalog

from 0 At the beginning RPC Iterative process of ：

• version0 edition ： Complete a with less than 100 lines of code RPC Example
• version1 edition ： Improve the common message format （request,response）, The client's dynamic proxy completes the request Encapsulation of message formats
• version2 edition ： Support the server to expose multiple service interfaces , Server program abstraction , Normalization
• version3 edition ： Use a high-performance network framework netty The realization of network communication , And the refactoring of client code
• version4 edition ： Custom message format , Support multiple serialization methods （java Native , json…）
• version5 edition : Implementation of server registration and discovery ,zookeeper As a registry
• version6 edition : Implementation of load balancing strategy

---

6.MyRPC edition 6

our RPC The overall framework already exists , Next, there are some modules that have expanded functions

Background knowledge

• Load balancing

Questions in this section

• If a service is supported by multiple providers , How to disperse the pressure of service providers

Upgrade process

1. Load balancing interface

/** *  Give the server address list , Choose one according to different load balancing strategies  */
public interface LoadBalance {
    
    String balance(List<String> addressList);
}

2. Two ways of implementation

/** *  Random load balancing  */
public class RandomLoadBalance implements  LoadBalance{
    
    @Override
    public String balance(List<String> addressList) {
    
        Random random = new Random();
        int choose = random.nextInt(addressList.size());
        System.out.println(" Load balancing selects " + choose + " The server ");
        return addressList.get(choose);
    }
}

/** *  Polling load balancing  */
public class RoundLoadBalance implements LoadBalance{
    
    private int choose = -1;
    @Override
    public String balance(List<String> addressList) {
    
        choose++;
        choose = choose%addressList.size();
        return addressList.get(choose);
    }
}

stay Service discovery methods Using load balancing in

List<String> strings = client.getChildren().forPath("/" + serviceName);

result

We started two service providers

It can be seen that the load balancing strategy has been successful

summary

In this version , We implement two strategies for load balancing ： Random and polling .

In this version , A fully functional RPC Already appeared , Of course, there is still a lot of work to be done in terms of performance and code quality .