Dubbo-Zookeeper注册中心；监控中心

「爱情、让人受尽委屈。」 2023-09-29 10:32 79阅读 0赞

一、ZooKeeper注册中心

对于服务提供方，它需要发布服务，而且由于应用系统的复杂性，服务的数量、类型也 不断膨胀；对于服务消费方，它最关心如何获取到它所需要的服务，而面对复杂的应用系统，需要管理大量的服务调用。

而且，对于服务提供方和服务消费方来说，他们还有可能兼具这两种角色，即需要提供服务，有需要消费服务。 通过将服务统一管理起来，可以有效地优化内部应用对服务发布使用的流程和管理。服务注册中心可以通过特定协议来完成服务对外的统一

Dubbo 提供的注册中心有如下几种类型可供选：

Multicast 注册中心：组播方式

Redis 注册中心：使用 Redis 作为注册中心

Simple 注册中心：就是一个 dubbo 服务。作为注册中心。提供查找服务的功能。

Zookeeper 注册中心：使用 Zookeeper 作为注册中心

Dubbo推荐使用 Zookeeper 注册中心

Zookeeper是Apache下一个高性能的，分布式的，开放源码的分布式应用程序协调服务。简称 zk

ZooKeeper主要服务于分布式系统，可以用ZooKeeper来做：统一配置管理、统一命名服务、分布式锁、集群管理

ZooKeeper官网

Apache ZooKeeper

注：

Zookeeper 运行需要 java 环境

（一）Windows下安装ZooKeeper

1、zookeeper官网 https://zookeeper.apache.org/index.html

https://zookeeper.apache.org/releases.html#download

2、下载之后解压到目标路径即可

（二）zoo.cfg配置文件

1、进入conf目录下，复制 zoo_sample.cfg文件，并将其改名为 zoo.cfg

2、修改zoo.cfg 配置文件

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_18_color_FFFFFF_t_70_g_se_x_16

配置文件主要参数如下：

  1. #ZK中的时间配置最小但域，其他时间配置以整数倍tickTime计算
  2. tickTime=2000
  3. #Leader允许Follower启动时在initLimit时间内完成数据同步，单位：tickTime
  4. initLimit=10
  5. #Leader发送心跳包给集群中所有Follower，若Follower在syncLimit时间内没有响应，那么Leader就认为该follower已经挂掉了，单位：tickTime
  6. syncLimit=5
  7. #配置ZK的数据目录
  8. dataDir=/usr/local/zookeeper/data
  9. #用于接收客户端请求的端口号
  10. clientPort=2181
  11. #配置ZK的日志目录
  12. dataLogDir=/usr/local/zookeeper/logs
  13. #ZK集群节点配置，端口号2888用于集群节点之间数据通信，端口号3888用于集群中Leader选举
  14. server.1=192.168.123.100:2888:3888
  15. server.2=192.168.123.101:2888:3888

进入到 bin 目录下，点击 zkServer.cmd

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_16_color_FFFFFF_t_70_g_se_x_16

或者 在 bin 目录下 输入 “cmd”命令

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_17_color_FFFFFF_t_70_g_se_x_16

看到绑定成功即可

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_20_color_FFFFFF_t_70_g_se_x_16

使用ZooKeeper示例

1、创建maven Java模块

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_8_color_FFFFFF_t_70_g_se_x_16

IDEA下执行install命令，打成jar包

2、创建 maven web 服务提供者

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_8_color_FFFFFF_t_70_g_se_x_16 1

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  3. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.   <modelVersion>4.0.0</modelVersion>
  7.   <groupId>com.mycompany</groupId>
  8.   <artifactId>dubbo-3-zk-userservice-provider</artifactId>
  9.   <version>1.0.0</version>
  10.   <packaging>war</packaging>
  12.   <dependencies>
  13.     <!--Spring依赖-->
  14.     <dependency>
  15.       <groupId>org.springframework</groupId>
  16.       <artifactId>spring-context</artifactId>
  17.       <version>5.1.4.RELEASE</version>
  18.     </dependency>
  19.     <dependency>
  20.       <groupId>org.springframework</groupId>
  21.       <artifactId>spring-webmvc</artifactId>
  22.       <version>5.1.4.RELEASE</version>
  23.     </dependency>
  25.     <!--dubbo依赖-->
  26.     <dependency>
  27.       <groupId>com.alibaba</groupId>
  28.       <artifactId>dubbo</artifactId>
  29.       <version>2.6.2</version>
  30.     </dependency>
  32.     <!--接口工程依赖-->
  33.     <dependency>
  34.       <groupId>com.mycompany.dubbo</groupId>
  35.       <artifactId>dubbo-3-zk-interface</artifactId>
  36.       <version>1.0.0</version>
  37.     </dependency>
  39.     <!-- zookeeper依赖 -->
  40.     <dependency>
  41.       <groupId>org.apache.curator</groupId>
  42.       <artifactId>curator-framework</artifactId>
  43.       <version>4.3.0</version>
  44.     </dependency>
  46.   </dependencies>
  48.   <build>
  49.     <plugins>
  50.       <!--JDK1.8编译插件-->
  51.       <plugin>
  52.         <artifactId>maven-compiler-plugin</artifactId>
  53.         <version>3.1</version>
  54.         <configuration>
  55.           <source>1.8</source>
  56.           <target>1.8</target>
  57.         </configuration>
  58.       </plugin>
  59.     </plugins>
  60.   </build>
  61. </project>

dubbo-zk-userservice-provider.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://dubbo.apache.org/schema/dubbo"
  4.        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
  6.     <!-- 服务提供者声明名称：必须保证服务名称的唯一性（dubbo内部使用的唯一标识符）-->
  7.     <dubbo:application name="dubbo-3-zk-userservice-provider" />
  9.     <!-- 访问服务协议的名称以及端口号，dubbo官方推荐使用dubbo协议，端口号默认20880
  10.         name：指定协议名称
  11.         port：指定协议的端口号（默认为20880）
  12.      -->
  13.     <dubbo:protocol name="dubbo" port="20880"/>
  15.     <!-- 使用zookeeper注册中心
  16.         指定注册中心地址和端口号
  17.     -->
  18.     <!--使用本机中的 zookeeper注册中心-->
  19.     <dubbo:registry address="zookeeper://localhost:2181" />
  20.     <!--使用linux系统中的zookeeper服务-->
  21. <!--    <dubbo:registry address="zookeeper://192.168.133.128:2181"/>-->
  23.     <!-- 暴露服务接口
  24.         dubbo:service
  25.         interface:暴露服务接口的全限定类名
  26.         ref:接口引用的实现类在spring容器中的标识
  27.         registry:如果不使用注册中心，值为：N/A
  28.      -->
  29.     <dubbo:service interface="com.mycompany.dubbo.service.UserService" ref="userService" />
  31.     <!-- 将接口实现类加载到spring容器 -->
  32.     <bean id="userService" class="com.mycompany.dubbo.service.impl.UserServiceImpl" />
  34. </beans>

如果有多个服务提供者

  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://dubbo.apache.org/schema/dubbo"
  4.        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
  6.     <!-- 服务提供者声明名称：必须保证服务名称的唯一性（dubbo内部使用的唯一标识符）-->
  7.     <dubbo:application name="dubbo-3-zk-userservice-provider" />
  9.     <!-- 访问服务协议的名称以及端口号，dubbo官方推荐使用dubbo协议，端口号默认20880
  10.         name：指定协议名称
  11.         port：指定协议的端口号（默认为20880）
  12.      -->
  13.     <dubbo:protocol name="dubbo" port="20880"/>
  15.     <!-- 使用zookeeper注册中心
  16.         指定注册中心地址和端口号
  17.     -->
  18.     <!--使用本机中的 zookeeper注册中心-->
  19.     <dubbo:registry address="zookeeper://localhost:2181" />
  20.     <!--使用linux系统中的zookeeper服务-->
  21. <!--    <dubbo:registry address="zookeeper://192.168.133.128:2181"/>-->
  23.     <!-- 暴露服务接口
  24.         dubbo:service
  25.         interface:暴露服务接口的全限定类名
  26.         ref:接口引用的实现类在spring容器中的标识
  27.         registry:如果不使用注册中心，值为：N/A
  28.      -->
  29.     <dubbo:service interface="com.mycompany.dubbo.service.UserService" ref="userService"  version="1.0.0" timeout="15000"/>
  30.     <dubbo:service interface="com.mycompany.dubbo.service.UserService" ref="userService2"  version="2.0.0" />
  32.     <!-- 将接口实现类加载到spring容器 -->
  33.     <bean id="userService" class="com.mycompany.dubbo.service.impl.UserServiceImpl" />
  34.     <bean id="userService2" class="com.mycompany.dubbo.service.impl.UserServiceImpl2" />
  36. </beans>

web.xml

  1. <context-param>
  2.         <param-name>contextConfigLocation</param-name>
  3.         <param-value>classpath:dubbo-zk-userservice-provider.xml</param-value>
  4.     </context-param>
  5.     <listener>
  6.         <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  7.     </listener>

3、创建maven web 消费者

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_8_color_FFFFFF_t_70_g_se_x_16 2

pom.xml

  1. <groupId>com.mycompany.dubbo</groupId>
  2.   <artifactId>dubbo-3-zk-consumer</artifactId>
  3.   <version>1.0.0</version>
  4.   <packaging>war</packaging>
  6.   <dependencies>
  7.     <!--Spring依赖-->
  8.     <dependency>
  9.       <groupId>org.springframework</groupId>
  10.       <artifactId>spring-context</artifactId>
  11.       <version>5.1.4.RELEASE</version>
  12.     </dependency>
  13.     <dependency>
  14.       <groupId>org.springframework</groupId>
  15.       <artifactId>spring-webmvc</artifactId>
  16.       <version>5.1.4.RELEASE</version>
  17.     </dependency>
  19.     <!--dubbo依赖-->
  20.     <dependency>
  21.       <groupId>com.alibaba</groupId>
  22.       <artifactId>dubbo</artifactId>
  23.       <version>2.6.2</version>
  24.     </dependency>
  26.     <!--接口工程依赖-->
  27.     <dependency>
  28.       <groupId>com.mycompany.dubbo</groupId>
  29.       <artifactId>dubbo-3-zk-interface</artifactId>
  30.       <version>1.0.0</version>
  31.     </dependency>
  33.     <!-- zookeeper依赖 -->
  34.     <dependency>
  35.       <groupId>org.apache.curator</groupId>
  36.       <artifactId>curator-framework</artifactId>
  37.       <version>4.3.0</version>
  38.     </dependency>
  40.   </dependencies>
  42.   <build>
  43.     <plugins>
  44.       <!--JDK1.8编译插件-->
  45.       <plugin>
  46.         <artifactId>maven-compiler-plugin</artifactId>
  47.         <version>3.1</version>
  48.         <configuration>
  49.           <source>1.8</source>
  50.           <target>1.8</target>
  51.         </configuration>
  52.       </plugin>
  53.     </plugins>
  54.   </build>

UserController

  1. @Controller
  2. public class UserController {
  4.     @Autowired
  5.     private UserService userService;
  7.     @RequestMapping(value = "/userDetail")
  8.     public String userDetail(Model model,Integer id){
  9.         //根据用户标识获取用户详情
  10.         User user = userService.queryUserById(id);
  12.         //获取用户总人数
  13.         Integer allUserCount = userService.queryAllUserCount();
  15.         model.addAttribute("user",user);
  16.         model.addAttribute("allUserCount",allUserCount);
  18.         return "userDetail";
  19.     }
  20. }

applicationContext.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"
  4.        xmlns:context="http://www.springframework.org/schema/context"
  5.        xmlns:mvc="http://www.springframework.org/schema/mvc"
  6.        xsi:schemaLocation="http://www.springframework.org/schema/beans
  7.        http://www.springframework.org/schema/beans/spring-beans.xsd
  8.        http://www.springframework.org/schema/context
  9.        http://www.springframework.org/schema/context/spring-context.xsd
  10.        http://www.springframework.org/schema/mvc
  11.        http://www.springframework.org/schema/mvc/spring-mvc.xsd">
  13.     <!--扫描组件-->
  14.     <context:component-scan base-package="com.mycompany.dubbo.controller"/>
  16.     <!--配置注解驱动-->
  17.     <mvc:annotation-driven/>
  19.     <!--视图解析器-->
  20.     <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
  21.         <property name="prefix" value="/"/>
  22.         <property name="suffix" value=".jsp"/>
  23.     </bean>
  24. </beans>

dubbo-zk-consumer.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://dubbo.apache.org/schema/dubbo"
  4.        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
  6.     <!--声明dubbo服务消费者名称:保证唯一性-->
  7.     <dubbo:application name="dubbo-3-zk-consumer"/>
  9.     <!--指定注册中心-->
  10.     <dubbo:registry address="zookeeper://localhost:2181"/>
  11.     <!--使用linux系统中的zookeeper服务-->
  12. <!--    <dubbo:registry address="zookeeper://192.168.133.128:2181"/>-->
  14.     <!--引用远程接口服务-->
  15.     <dubbo:reference id="userService" interface="com.mycompany.dubbo.service.UserService"/>
  17. </beans>

如果有多个消费者

  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://dubbo.apache.org/schema/dubbo"
  4.        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
  6.     <!--声明dubbo服务消费者名称:保证唯一性-->
  7.     <dubbo:application name="dubbo-4-zk-multi-consumer"/>
  9.     <!--指定注册中心-->
  10.     <dubbo:registry address="zookeeper://localhost:2181"/>
  11.     <!--使用linux系统中的zookeeper服务-->
  12. <!--    <dubbo:registry address="zookeeper://192.168.133.128:2181"/>-->
  14.     <!--引用远程接口服务-->
  15.     <dubbo:reference id="userService" interface="com.mycompany.dubbo.service.UserService" version="1.0.0" />
  16.     <dubbo:reference id="userService2" interface="com.mycompany.dubbo.service.UserService" version="2.0.0" />
  18. </beans>

web.xml

  1. <servlet>
  2.         <servlet-name>dispatcherServlet</servlet-name>
  3.         <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
  4.         <init-param>
  5.             <param-name>contextConfigLocation</param-name>
  6.             <param-value>classpath:applicationContext.xml,classpath:dubbo-zk-consumer.xml</param-value>
  7.         </init-param>
  8.     </servlet>
  9.     <servlet-mapping>
  10.         <servlet-name>dispatcherServlet</servlet-name>
  11.         <url-pattern>/</url-pattern>
  12.     </servlet-mapping>

配置Tomcat访问

643beb5e681f434d9f6b464dafda6d6e.png

二、监控中心

dubbo 的使用，其实只需要有注册中心，消费者，提供者这三个就可以使用了，但是并不能看到有哪些消费者和提供者，为了更好的调试，发现问题，解决问题，因此引入dubbo-admin

通过 dubbo-admin 可以对消费者和提供者进行管理。可以在 dubbo 应用部署做动态的调整，服务的管理。

1、下载监控中心，https://github.com/alibaba/dubbo

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_20_color_FFFFFF_t_70_g_se_x_16 1

2、通过IDEA将其打包war

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_20_color_FFFFFF_t_70_g_se_x_16 2

3、把 dubbo-admin.war 文件拷贝到 tomcat 的 webapps

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_13_color_FFFFFF_t_70_g_se_x_16

4、通过压缩工具打开dubbo-admin-2.5.10.war包 应用的 WEB-INF/dubbo-properties 文件，内容如下

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_12_color_FFFFFF_t_70_g_se_x_16

5、在浏览器地址栏输入 http://localhost:8080/dubbo-admin ；访问监控中心-控制台

watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBATWluZ2dlUWluZ2NodW4_size_20_color_FFFFFF_t_70_g_se_x_16 3

发表评论

表情：
评论列表 （有 0 条评论，79人围观）

还没有评论，来说两句吧...

相关阅读

    相关 注册中心zookeeper

    概念 Zookeeper是一个分布式、可靠的、可扩展的协调服务，为分布式应用提供一致性服务。它是树型结构，能做到集群管理数据，当提供者出现断电等异常停机时，zk能自动删除

    旧城等待，旧城等待，/ 0 赞/ 440 阅读