标签:解压 min 调用 ack try 两种 2.0 进入 网上
本次和大家分享的是dubbo框架应用的初略配置和zookeeper注册中心的使用;说到注册中心现在我使用过的只有两种:zookeeper和Eureka,zk我结合dubbo来使用,而Eureka结合springcloud使用,因此后面将和大家分享一些关于微服务的一些篇章,希望对你有好的帮助。
安装注册中心zookeeper
dubbo框架之provider和consumer
dubbo-admin部署
首先,我们需要在网上搜索下zookeeper下载地址,我这里是linux系统,所以下载了zookeeper-3.3.6.tar.gz包,通过 tar -zxvf zookeeper-3.3.6.tar.gz 解压出来,需要注意的是一般的包里面配置文件都是默认的sample版本,zookeeper默认配置文件名只zoo.cfg,为了不每次指定文件名来运行,因此需要我们自己在conf目录下创建一个名称为zoo.cfg的配置文件,文件内容可以从zoo_sample.cfg拷贝或者把这个文件重命名都行,内容如下 vim zoo.cfg :
1 # The number of milliseconds of each tick 2 tickTime=2000 #心跳频率 3 # The number of ticks that the initial 4 # synchronization phase can take 5 initLimit=10 #限制连接 6 # The number of ticks that can pass between 7 # sending a request and getting an acknowledgement 8 syncLimit=5 9 # the directory where the snapshot is stored. 10 dataDir=/tmp/zookeeper #数据存储文件夹 11 # the port at which the clients will connect 12 clientPort=2081 #zookeeper对外的端口
这里就不修改参数信息了,采用默认;简单介绍下linux下怎么编辑文件内容的常用的几个命令:
vim zoo.cfg:查看文件内容
insert:执行插入命令
esc:取消命令,再接着按:q:退出,:wq:保存并退出
当有了zoo.cfg后,我们只需要进入她的bin目录里面查找zkServer.sh文件,通过执行: ./zkServer.sh start 命令启动zookeeper注册中心,正常启动提示如:
通常情况是zookeeper作为注册中心在单独的一台服务器上,而程序(这里指我本地)需要调用另外注册中心需要检查zookeeper开放的端口是否能通,我本地是window10因此可以不需要通过zookeeper客户端去验证端口,只需要通过 telnet ip 2081 就能检测出是否端口开放;
首先为了方便,我们需要定义一个统一的接口,该接口就是业务抽出来的公用接口,我们单独对这种接口包装成一个module,我这里是dubbo_api,我们在这个module中定义如下的接口:
1 public interface UserService { 2 3 List<MoUser> getUsers(); 4 }
然后,创建一个provider模块,这个模块去依赖dubbo_api模块,并且实现UserService接口,代码如:
1 public class UserServiceImpl implements UserService { 2 3 @Value("${server.port}") 4 private int port; 5 6 /** 7 * @return 8 */ 9 @Override 10 public List<MoUser> getUsers() { 11 12 List<MoUser> list = new ArrayList<>(); 13 for (int i = 0; i < 5; i++) { 14 MoUser user = new MoUser(); 15 user.setUserName("shenniu" + i); 16 user.setUserPwd("端口:" + port); 17 list.add(user); 18 } 19 return list; 20 } 21 }
作为服务提供者,要使用dubbo框架就需要先引入dubbo,然后再做一些配置,首先我们需要在dubbo_provider模块通过maven引入dubbo依赖,注册中心用的zookeeper所以也需要通过maven引入相应的依赖:
1 <dependency> 2 <groupId>org.apache.zookeeper</groupId> 3 <artifactId>zookeeper</artifactId> 4 <version>3.4.8</version> 5 </dependency> 6 <dependency> 7 <groupId>com.101tec</groupId> 8 <artifactId>zkclient</artifactId> 9 <version>0.3</version> 10 </dependency> 11 <dependency> 12 <groupId>com.alibaba</groupId> 13 <artifactId>dubbo</artifactId> 14 <version>2.5.3</version> 15 <exclusions> 16 <exclusion> 17 <groupId>org.springframework</groupId> 18 <artifactId>spring</artifactId> 19 </exclusion> 20 </exclusions> 21 </dependency> 22 <dependency> 23 <groupId>com.example</groupId> 24 <artifactId>dubbo_api</artifactId> 25 <version>0.0.1-SNAPSHOT</version> 26 </dependency>
完成依赖后,剩下的就是对dubbo的provider的配置了,创建resources/dubbo-conf/server.xml的配置文件,文件内容:
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 4 xsi:schemaLocation="http://www.springframework.org/schema/beans 5 http://www.springframework.org/schema/beans/spring-beans.xsd 6 http://code.alibabatech.com/schema/dubbo 7 http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> 8 9 <!-- 提供者名称 --> 10 <dubbo:application name="demo-provider" /> 11 12 <!-- zookeeper注册中心的服务地址 --> 13 <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" /> 14 15 <!-- 用dubbo协议在20880端口暴露服务,协议通信端口 --> 16 <dubbo:protocol name="dubbo" port="20880" /> 17 18 <!-- 用户服务接口 --> 19 <dubbo:service interface="service.UserService" ref="userService" /> 20 21 <!-- 用户服务接口实现 --> 22 <bean id="userService" class="com.example.demo.service.UserServiceImpl"/> 23 </beans>
在DubboProviderApplication入口增加资源导入 @ImportResource("classpath:dubbo-conf/*.xml") ,到这里我们的服务提供端就完成了,查看下启动日志:
服务提供者启动暂无异常,再来看调用方创建一个dubbo_consumer的moduel,同样去引入dubbo_api公共接口的模块依赖,然后创建一个UserController,并暴露一个get的user接口:
1 @RestController 2 public class UserController { 3 @Autowired 4 private UserService userService; 5 6 @GetMapping("/users") 7 public List<MoUser> getUsers(){ 8 9 return userService.getUsers(); 10 } 11 }
这里的UserService是公共接口的注入;编码完成后剩下的就是consumer端引入dubbo和zookeeper依赖了:
1 <dependency> 2 <groupId>org.apache.zookeeper</groupId> 3 <artifactId>zookeeper</artifactId> 4 <version>3.4.8</version> 5 </dependency> 6 <dependency> 7 <groupId>com.101tec</groupId> 8 <artifactId>zkclient</artifactId> 9 <version>0.3</version> 10 </dependency> 11 <dependency> 12 <groupId>com.alibaba</groupId> 13 <artifactId>dubbo</artifactId> 14 <version>2.5.3</version> 15 <exclusions> 16 <exclusion> 17 <groupId>org.springframework</groupId> 18 <artifactId>spring</artifactId> 19 </exclusion> 20 </exclusions> 21 </dependency>
我们同样创建名称resources/dubbo-conf/client.xml的配置文件,并在application入口引入这个资源:
1 @ImportResource("classpath:dubbo-conf/*.xml") 2 @SpringBootApplication 3 public class DubboConsumerApplication { 4 public static void main(String[] args) { 5 SpringApplication.run(DubboConsumerApplication.class, args); 6 } 7 }
client.xml的配置内容如:
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 4 xsi:schemaLocation="http://www.springframework.org/schema/beans 5 http://www.springframework.org/schema/beans/spring-beans.xsd 6 http://code.alibabatech.com/schema/dubbo 7 http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> 8 9 <!-- 服务名 --> 10 <dubbo:application name="demo-consumer" /> 11 12 <!-- zookeeper注册中心暴露服务地址 --> 13 <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" /> 14 15 <!-- 用户服务接口 --> 16 <dubbo:reference id="userService" interface="service.UserService" /> 17 18 </beans>
这个时候一个简单的服务提供者,服务调用者配置和编码都完成了,3个module如下:
然后分别启动provider,consumer;再通过consumer暴露的controller接口请求接口,我这里的地址是 http://localhost:8082/users :
效果是Consumer通过注入的UserService接口依赖调用getUsers()拿到了Provider返回的结果,也表示此次dubbo框架的简单使用算成功了。
作为一个流行的rpc框架dubbo有这一个开源的监控工具dubbo-admin,不得不说现在网上现成的dubbo-admin.war包要么现在下来不能用要么就是下载需要csdn积分,版本多种多样有点坑啊,果断去git拉源码自己打包,git地址: https://github.com/apache/incubator-dubbo-ops ,拉下来后我们只需要关注dubbo-admin工程,其他的暂可忽略;打开项目后,我们需要改的地方只有如下截图配置(也可以对打包后的配置文件修改):
1 #zookeeper配置地址和端口 2 dubbo.registry.address=zookeeper://127.0.0.1:2081 3 #后台登录密码 4 dubbo.admin.root.password=root 5 dubbo.admin.guest.password=guest
执行打包后,能得到名称:dubbo-admin-2.0.0.war包,然后放在tomcat中,再通过浏览器浏览,账号和密码:都是root;登录后能看到我们之前的启动的provider和consumer在里面,这就是dubbo-admin监控注册中心服务的界面,能够直接对这些服务做点击操作,其他的不多说自行尝试吧。
dubbo+zookeeper+springboot构建服务
标签:解压 min 调用 ack try 两种 2.0 进入 网上
原文地址:https://www.cnblogs.com/wangrudong003/p/9024992.html