Dubbo的入门使用
前言:Dubbo是一款java RPC(远程过程调用)框架。1、Dubbo运行流程:(1)Dubbo框架启动,容器Container一启动,服务提供者Provider会将提供的服务信息注册到注册中心Registry,注册中心就知道有哪些服务上线了;当服务消费者Consumer启动,它会从注册中心订阅subscribe所需要的服务。若某个服务提供者变更,比如某个机器下线宕机,注册中心基于长连接的方式
前言:Dubbo是一款java RPC(远程过程调用)框架。
1、Dubbo运行流程:
(1)Dubbo框架启动,容器Container一启动,服务提供者Provider会将提供的服务信息注册到注册中心Registry,注册中心就知道有哪些服务上线了;当服务消费者Consumer启动,它会从注册中心订阅subscribe所需要的服务。
若某个服务提供者变更,比如某个机器下线宕机,注册中心基于长连接的方式将变更信息通知给消费者。
消费者可以调用服务提供者的服务,同时会根据负载均衡算法选择服务来调用。
每次的调用信息、服务信息等会定时统计发送给监控中心Monitor,监控中心能够监控服务的运行状态。
2、在使用测试Dubbo之前,我们需要先搭建一个注册中心Registry,服务都注册到注册中心,官方推荐使用Zookeeper注册中心
参照zookeeper文档:http://dubbo.apache.org/zh-cn/docs/user/references/registry/zookeeper.html
drwxr-xr-x. 11 zhou zhou 4096 4月 22 16:05 zookeeper-3.4.6
(1)注意:将conf目录下的zoo_sample.cfg复制改名为zoo.cfg
端口号:2181
3、搭建Monitor监控中心
4、服务化最佳实践 -- 参照Dubbo官方文档
分包
建议将服务接口、服务模型、服务异常等均放在 API 包中,因为服务模型和异常也是 API 的一部分,这样做也符合分包原则:重用发布等价原则(REP),共同重用原则(CRP)。
5、入门demo 可以参照Dubbo官方文档 -- 快速启动 http://dubbo.apache.org/zh-cn/docs/user/quick-start.html
6、使用dubbo-admin管理控制台
第一种方法:通过jar
(1)修改incubator-dubbo-ops-master\dubbo-admin\src\main\resources目录下的application.properties配置文件:
(2) dubbo github下载incubator-dubbo-ops-master.zip,解压后,将dubbo-admin打包jar
打包之前,需要进行dubbo-admin目录下的application.properties配置dubbo.registry.address=zookeeper://192.168.93.101:2181
在target目录下出现
接下来只需要运行这个jar
(3) java -jar 运行
(4) 访问:http://localhost:7001/
7、dubbo demo (jar)
(1)关系图
创建服务提供者 userserviceprovider、服务消费者orderserviceconsumer和接口 gmall-interface
/**
* 1、将服务提供者注册到注册中心(暴露服务)
* 1)导入dubbo依赖
* 2)配置服务提供者
* 2、让服务消费者去注册中心订阅服务服务提供者的服务地址
* @author zhou
* @create 2020/5/22
*/
(2)选择zookeeper客户端
(3)
参照:http://dubbo.apache.org/zh-cn/docs/user/quick-start.html
(4)服务提供方 用 Spring 配置声明暴露服务
·引入依赖
<!--引入dubbo-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.0</version>
</dependency>
<!--注册中心使用的是zookeeper,需要引入操作zookeeper的客户端-->
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>2.13.0</version>
</dependency>
<!--1.指定当前服务/应用的名字(同样的服务名字相同,不要和别的服务同名)-->
<dubbo:application name="userseviceprovider"></dubbo:application>
<!--2.指定注册中心的位置-->
<dubbo:registry protocol="zookeeper" address="192.168.93.101:2181"></dubbo:registry>
<!--3.指定服务消费方访问服务提供方的通信规则-->
<dubbo:protocol name="dubbo" port="20880"></dubbo:protocol>
<!--4.暴露服务-->
<dubbo:service interface="com.dhu.service.UserService" ref="userServiceImpl"></dubbo:service>
<!--服务的实现-->
<bean id="userServiceImpl" class="com.dhu.service.impl.UserServiceImpl"></bean>
(5)编写测试类
System.in.read(); //程序阻塞,等待读取一个字符
很关键,这样能保证服务提供方一直处于运行状态,后面才能为服务消费方提供服务。
public class MyApp {
public static void main(String[] args) throws IOException {
ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("provider.xml");
ioc.start();
System.in.read(); //程序阻塞,等待读取一个字符
}
}
8、配置服务的消费方,它来调用服务提供者
(1)引入依赖
<!--引入dubbo-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.0</version>
</dependency>
<!--注册中心使用的是zookeeper,需要引入操作zookeeper的客户端-->
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>2.13.0</version>
</dependency>
(2)通过 Spring 配置引用远程服务
<dubbo:application name="orderserviceconsumer"></dubbo:application>
<dubbo:registry address="zookeeper://192.168.93.101:2181"></dubbo:registry>
<!--声明需要调用的远程服务的接口-->
<dubbo:reference interface="com.dhu.service.UserService" id="userService"></dubbo:reference>
解释:OrderServiceImpl中使用到UserService, 只是接口,但是我们利用了Dubbo配置远程服务调用,
interface="com.dhu.service.UserService" 这是一个远程服务引用,Dubbo会从注册中心找到UserService接口真正的实现类对象,并调用方法。
/**
* 1、将服务提供者注册到注册中心(暴露服务)
* 1)导入dubbo依赖
* 2)配置服务提供者
* 2、让服务消费者去注册中心订阅服务服务提供者的服务地址
* @author zhou
* @create 2020/5/22
*/
@Service
public class OrderServiceImpl implements OrderService {
@Autowired
private UserService userService;
@Override
public void initOrder(String userId) {
//1.查询用户的收获地址
List<UserAddress> list = userService.getUserAddressList(userId);
for (UserAddress userAddress : list) {
System.out.println(userAddress);
}
}
}
(3)编写测试类
System.in.read();保证消费方一直出于运行
public class MyApplication {
@SuppressWarnings("resource")
public static void main(String[] args) throws IOException {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("consumer.xml");
OrderService orderService = context.getBean(OrderService.class);
orderService.initOrder("1");
System.in.read();
}
}
必须保证两个服务都启动运行:
(4)Dubbo Admin界面
更多推荐
所有评论(0)