导航：首页 > 网络安全 >

从头开始搭建一个dubbo+zookeeper平台

发表于：2025-02-04 作者：千家信息网编辑

千家信息网最后更新 2025年02月04日，首先，看下一般网站架构随着业务的发展，逻辑越来越复杂，数据量越来越大，交互越来越多之后的常规方案演进历程。其次，当服务越来越多之后，我们需要做哪些服务治理？最后，是dubbo的架构图注册中心的选择du

千家信息网最后更新 2025年02月04日从头开始搭建一个dubbo+zookeeper平台

首先，看下一般网站架构随着业务的发展，逻辑越来越复杂，数据量越来越大，交互越来越多之后的常规方案演进历程。

其次，当服务越来越多之后，我们需要做哪些服务治理？

最后，是dubbo的架构图

注册中心的选择

dubbo支持多种类型的注册中心：

Multicast注册中心
Zookeeper注册中心
Redis注册中心
Simple注册中心

这里我们选择zookeeper，其实类型的优点缺点可详细查看文档。

1:zookeeper的安装,还是采用docker这一招鲜的run命令来安装zookeeper

docker run -dit --name zookeeper  --hostname  zookeeper-host  -v /data:/data -p 2181:2181 jplock/zookeeper:latest

2:安装zkui，可以参考zkui的项目地址来安装，它提供了一个管理界面，可以针对zookeepr的节点值进行CRUD操作，同时也提供了安全认证，按照如下几步就可以完成安装。

mvn clean install，执行前需要安装java环境，maven环境，执行成功后会生成一个jar文件。
将config.cfg复制到上一步生成的jar文件所在目录，然后修改配置文件中的zookeeper地址。
执行 jar. ( nohup java -jar zkui-2.0-SNAPSHOT-jar-with-dependencies.jar & )，注意后面的那个&，是指不退出的意思。
测试，http://localhost:9090，如能看到如下页面则代表zookeeper安装运行正常。

下面是创建dubbo服务以及使用dubbo服务的过程：

dubbo提供者，创建一个java工程，注意以下几点：

包依赖，引入如下三个主要的包就可以了，主要是spring,dubbo以及zkclient

            org.springframework            spring-context            ${spring-framework.version}                            com.alibaba            dubbo            2.4.10                                                spring                    org.springframework                                                        com.101tec            zkclient            0.3

定义接口，这里为了演示，简单定义了一个返回产品名称的接口。

public interface IProduct {    String getProductName();}

接口实现

@Servicepublic class ProductService implements IProduct{    public String getProductName() {               return "jim";    }}

服务启动函数
- 加载配置文件
- 调用context.start()
- 执行一个不退出程序的操作，这里有很多种做法。

public class App {    private final static Logger logger = LoggerFactory.getLogger(App.class);    public static void main(String[] args) {        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(                "classpath*:applicationContext.xml");        context.start();        logger.info("dubbo service begin to start");        try {            System.in.read();        } catch (IOException e) {            // TODO Auto-generated catch block            e.printStackTrace();        }    }}

服务配置文件，这里需要指出的是：
- dubbo:service的定义配合了dubbo:annotation，ref="productService",是指定的一个id，实际的实现类通过注解扫描来完成的，并没有在配置文件中指定实现类，后面的消费者配置文件中会有所体现。
- dubbo:application中，可以指定logger的实现接口。
- dubbo:protocol中，可以指定是否启动访问日志，这个对有时排查线上问题非常有帮助。

dubbo消费者

消费者配置文件，它的配置相对提供者要简单很多：
- 指定消费者的名称，这个可以随意，不需要与提供者做任务相关联的匹配。
- 指定协定类型，zookeeper地址。
- 指定引用的服务接口，注意这里的id就与服务提供者定义的ref值相同。

接口注解定义以及接口调用

@Controllerpublic class HomeController {    private static final Logger logger = LoggerFactory.getLogger(HomeController.class);    @Autowired    private IProduct productService;    @RequestMapping(value = "/", method = RequestMethod.GET)    public String home(Locale locale, Model model) {        logger.info("Welcome home! The client locale is {}.", locale);               String productName=this.productService.getProductName();        model.addAttribute("name", productName);        return "home";    }}

dubbo admin

有一个UI工具可以针对dubbo服务进行管理，可惜我没有在官方文档提供的链接中下载成功，随后从其它地方虽然下载完成了，但在安装部署方面暂时遇到了一定的问题，需要手续研究解决。

正常应该可以看到如下界面：