perf[net]: 优化了comsumer消费方式选择

This commit is contained in:
meiwei
2022-07-01 12:12:48 +08:00
parent 694668d7e4
commit a7741f0fc2
12 changed files with 96 additions and 34 deletions
@@ -32,6 +32,8 @@ public class ProtocolModule {
*/
private int version;
private String loadBalancer;
private int group;
private transient int hash;
@@ -56,8 +58,9 @@ public class ProtocolModule {
this.perfectHash();
}
public ProtocolModule(String name, String group) {
public ProtocolModule(String name, String loadBalancer, String group) {
this.name = name;
this.loadBalancer = loadBalancer;
this.group = Integer.parseInt(group);
}
@@ -114,6 +117,14 @@ public class ProtocolModule {
this.version = version;
}
public String getLoadBalancer() {
return loadBalancer;
}
public void setLoadBalancer(String loadBalancer) {
this.loadBalancer = loadBalancer;
}
public int getGroup() {
return group;
}