服务提供者-版本1
@Service(timeout = 3000,retries = 2)
public class HelloDubboServiceImpl implements HelloDubboService{
public String sayHello(){
System.out.println("==sayHello==");
return "Hello Dubbo ... ";
}
}
服务提供者-版本2
@Service(version="v1.0.2")
public class HelloDubboServiceImpl2 implements HelloDubboService{
public String sayHello(){
System.out.println("==New sayHello 2==");
return "New Hello Dubbo ... ";
}
}
服务消费者
@RestController("/test/*")
public class TestController{
@Reference(version="v1.0.2")
private HelloDubboService helloDubboService;
@GetMapping("sayHello")
public String testSayHello(){
return helloDubboService.sayHello();
}
}
序列化:将
Java
实体对象转化为流的数据进行数据传输,需要实体对象实现序列化接口
反序列化:将流的数据转化为Java
实体对象
Dubbo
内部已经将序列化和反序列化过程进行了封装,只需要在实体类中实现序列化接口即可
如果注册中心宕机了,服务也可以正常访问,原因是因为
Dubbo
的服务消费者在第一次调用时,会将服务提供者的地址缓存到本地,下次再调用的时候就不会在访问注册中心了。
当服务提供者地址发生变化时,注册中心会通知服务消费者,服务消费者会把最新的地址缓存到本地。
**注意:注册中心宕机后,新服务不能被注册中心注册和访问,服务消费者访问服务提供者时,只能访问旧的服务地址,新的服务不会被注册。 **
服务消费者调用服务提供者时,发生了阻塞,这时就会出现消费者一致等待的现象
当大量消费者同时调用请求时,便会造成大量的线程堆积,从而使服务消费者服务压力过大,造成雪崩。
Dubbo
利用了超时处理机制,设置超时时间后,如果请求在这个时间内没有完成访问,则会自动断开连接,释放资源,超时时间默认值是1000ms
@Service(timeout=3000,retries=2)
超时时间和重试次数
Dubbo
的默认值为“2”
,加上原本线程访问时的一次,一共3次
,如果调用时失败(1次),Dubbo
会在根据配置继续重试(默认retries=2
次),一共3次。
如果在服务提供者方设置了超时时间@Service(timeout = 3000)
,在服务消费者中也设置了超时时间@Reference(timeout = 2000)
,此时服务提供者上的超时时间便会失效
超时时间一般设置在服务提供者方,消费者只需要调用访问即可。