<!--服务占用本机的端口-当本机启动多个服务时须保持不同-->
<dubbo:protocol port=""/>
<!--dubbo的配置-->
<!--1.配置项目的名称,唯一-->
<dubbo:application name="dubbo-service"/>
<!--2.配置注册中心的地址-->
<dubbo:registry address="zookeeper://192.168.23.129:2181" timeout="250000"/>
<!--3.配置dubbo包扫描,注解注册服务-->
<!-- <dubbo:annotation package="com.yh1.impl" />-->
<!--3.2xml配置方式注册服务,类上不需要注解-->
<dubbo:service interface="com.yh.ours.UserService" ref="demoService"/>
<bean id="demoService" class="com.yh1.impl.UserServiceImpl"/>
查询出数据后返回给消费者时所执行的便是序列化
<groupId>org.yh</groupId>
<artifactId>debbo-interface</artifactId>
<version>1.0-SNAPSHOT</version>
<dependencies>
<!--被依赖资源-->
<dependency>
<groupId>org.yh</groupId>
<artifactId>dubbo-pojo</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
序列化和反序列化操作dubbo已经封装好,只需让pojo类实现接口即可
eg:
//必须实现Serializable
//一个实体类用于 模仿序列化和反序列化操作
public class User implements Serializable {
int id;
String name;
public User() {
}
public User(int id, String name) {
this.id = id;
this.name = name;
}
//省略get和set方法
Cotroller代码
@RequestMapping("/find.do")
public User find(int id){
return userService.findById(id);
}
问:注册中心挂了,服务是否可以正常访问?
答:可以,当第一次访问后,会将服务地址缓存至本地
但是当服务的地址变了以后就不行了,需要重新访问注册中心获取
问:消费者创建线程调用提供者服务,如果调用失败或者提供者查询时间过长或挂了,则消费者将一直等待
@Service
public class UserServiceImpl implements UserService {
@Override
public User findById(int id) {
//此处让服务睡5秒,用来演示超时操作
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
User user=new User(1,"jack");
return user;
}
}
解决:设置timeout属性值来控制超时时间
<!--2.配置注册中心的地址-->
<dubbo:registry address="zookeeper://192.168.23.129:2181" timeout="250000"/>
问题:出现了网络抖动网突然断了一下,断了3s超时时间设置是1s,则这一次请求就会失败,则会重新发送请求,一共发送3次
解决1:通过retries属性类设置重试次数。默认为2
灰度发布:新功能时,让一部分用户使用新版本,稳定后让全部用户使用新的版本。
使用:使用version属性来设置和调用同一个接口的不同版本
eg:公共接口模块中的UserService接口在服务提供者中有俩实现类UserServiceImpl1和UserServiceImpl2
在服务提供者的UserServiceImpl1@Service(version=“v1.0”)中设置version和UserServiceImpl2@Service(version=“v2.0”)
在消费者的@Reference(version=“v1.0 or v2.0”)中设置version来选择使用哪个版本
注:此处检验失败,原因未知
适用于集群环境,相同的服务部署在多台机器上
模拟步骤:
1.在服务提供者的@Service注解中添加weight属性,配置权重(可在服务内打印一句话来区别不同的服务)
2.启动该服务tomcat7:run
3.更改三个端口号后继续1,2,3步骤,直至启动三个服务器为止,保持权重不同
4.在消费者的@reference注解中配置loadbalance属性(共有四个值下面有)
5.启动服务,开始模拟
1.
<!--tomcat插件-->
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<version>2.1</version>
<configuration>
<port>8000</port>
<path>/</path>
</configuration>
</plugin>
2.
<dubbo:protocol port="20881"/>
3.
<!--dubbo的配置-->
<!--1.配置项目的名称,唯一-->
<dubbo:application name="dubbo-service">
<!--dubbo的pos服务一个服务会启动一次,故一台机器时不同服务需要更改-->
<dubbo:parameter key="qos.port" value="33331"/>
</dubbo:application>
问题: 消费者调用集群中某一机器出错了,该如何处理?