文章摘要
本文介绍Dubbo中通过指定IP:Port调用Provider集群特定实例的方法。当多个Provider注册到注册中心时，消费者可在RpcContext中动态设置Address对象（包含目标IP和端口），配合@DubboReference的router=address参数，实现精准路由到指定实例，适用于灰度发布、调试等场景。
有的时候博客内容会有变动，首发博客是最新的，其他博客地址可能会未同步,认准
https://blog.zysicyj.top
全网最细面试题手册，支持艾宾浩斯记忆法。这是一份最全面、最详细、最高质量的 java面试题，不建议你死记硬背，只要每天复习一遍，有个大概印象就行了。 https://store.amazingmemo.com/chapterDetail/1685324709017001`
对于Provider集群中注册的多个实例，指定Ip:Port进行调用
背景
当多个Provider注册到注册中心时，可以通过在RpcContext中动态的指定其中一个实例的Ip，Port进行Dubbo调用。
示例
- provider demo
假定提供2个provider注册于注册中心，分别为10.220.47.253:20880;10.220.47.253:20881;
// 10.220.47.253:20880
@Service(interfaceClass = TestService.class)
public class TestServiceImpl implements TestService {
@Override
public String sayHello(String name) {
return "Hello "+name+" i am provider1";
}
}
// 10.220.47.253:20881
@Service(interfaceClass = TestService.class)
public class TestServiceImpl implements TestService {
@Override
public String sayHello(String name) {
return "Hello "+name+" i am provider2";
}
}
- consumer demo
@DubboReference引入provider，其中设定parameters = {“router”,“address”},指定address路由方式。
对于要调用的实例，指定Ip，Port构造Address对象，并设置RpcContext键为"address"，value为该对象。
// 需要依赖的class
import org.apache.dubbo.rpc.RpcContext;
import org.apache.dubbo.rpc.cluster.router.address.Address;
@RestController
public class TestServiceConsumer {
@DubboReference(interfaceClass = TestService.class,group = "dev",parameters = {"router","address"})
private TestService testService;
@GetMapping("/invokeByIpPortSpecified")
public String invokeByIp(){
try {
// 根据provider的ip,port创建Address实例
Address address = new Address("10.220.47.253", 20880);
RpcContext.getContext().setObjectAttachment("address", address);
return testService.sayHello("Tom");
}catch (Throwable ex){
return ex.getMessage();
}
}
}
- 执行结果
可以看到，多次执行，始终返回"Hello Tom i am provider1",即始终路由到20880端口所在实例。
>curl http://localhost:8081/invokeByIpPortSpecified
>Hello Tom i am provider1
本文是原创文章，采用 CC BY-NC-SA 4.0 协议，完整转载请注明来自 小朱
评论
隐私政策
0/500
滚动到此处加载评论...