关于Dubbo以及Zookeeper的介绍和操作教程版权声明

原创

小哥 2年前 (2022-12-30) 阅读数 75 #大杂烩

Dubbo是什么？

Dubbo是一个致力于提供高性能和透明的分布式服务框架RPC远程服务调用场景，以及SOA服务治理方案。简单地说，dubbo它是一个服务框架。如果没有分布式需求，则不需要。仅在分发时dubbo这样一个分布式服务框架的需求本质上是一个服务调用，说白了，是一个用于远程服务调用的分布式框架（再见）。Web Service模式中的WSdl，以服务提供商和消费者的方式。dubbo上注册）
其核心部分包含:

远程通讯: 提供对各种基于长连接的访问NIO框架抽象封装，包括多线程模型、序列化和“请求”-信息交换的“响应”模式。
集群容错: 基于接口方法提供透明的远程过程调用，包括多协议支持和集群支持，如软负载平衡、容错、地址路由和动态配置。
自动发现: 基于注册表目录服务，服务使用者可以动态地查找服务提供者，使地址透明，并使服务提供者能够平滑地增加或减少机器。
Dubbo你能做什么？

1.透明的远程方法调用与本地方法一样调用远程方法，配置简单，无API侵入。
2.软负载平衡和容错机制，可在intranet中替换。F5以及其他硬件负载平衡器，以降低成本和单点。

自动服务注册和发现，不再需要写死服务提供商地址，注册中心基于接口名称查询服务提供商IP地址，以及平滑添加或删除服务提供商的能力。

Dubbo采用全 spring 配置方法，透明访问应用程序，无应用程序API入侵，只需使用Spring加载Dubbo该配置可以是，Dubbo基于Spring的Schema扩展名已加载。

之前使用Web Service，我想测试接口可以通过soapui或LR进行功能或性能测试。但现在使用Dubbo，接口不能直接交互，我试图通过模拟消费者地址进行测试，结果不堪入目然后再次使用。 jmeter 通过junit测试，但仍需要继续dubbo上去注册，如果你不提供源代码，这个测试用例不容易编写。....

dubbo的架构

dubbo架构图如下：

节点角色描述：

Provider: 公开服务的服务提供程序。

Consumer: 调用远程服务的服务使用者。

Registry: 服务注册和发现的注册表。

Monitor: 统计服务呼叫数和呼叫时间的监控中心。

Container : 服务运行容器。

我认为这是非常好的，角色是明确的，可以根据每个节点角色的状态来确定服务是否正常。

呼叫关系描述：

0 服务容器负责启动、加载和运行服务提供程序。

服务提供程序在启动时向注册表注册它提供的服务。
服务使用者向注册中心订阅启动时所需的服务。
注册表向使用者返回一个服务提供者地址列表，如果有更改，则注册表会根据长连接将更改数据推送给使用者。
服务使用者根据软负载平衡算法从提供者地址列表中选择要调用的提供者，如果调用失败，则选择另一个调用。
服务消费者和提供商在存储器中累积呼叫次数和呼叫时间，并每分钟定期向监控中心发送统计数据。

dubbo的容错性显而易见，性能尚未测试，需要删除系统的一页5子接口，最初想建议缓存，但无法采用业务关系，仍需研究dubbo性能调整问题...

dubbo使用方法。

Dubbo采用全Spring配置方法，透明访问应用程序，无应用程序API入侵，只需使用Spring加载Dubbo该配置可以是，Dubbo基于Spring的Schema扩展名已加载。如果不想使用Spring配置，希望通过。API拨打电话的方式（不推荐）

下面我们来看看spring配置的写入方法:

服务提供商：

1. 下载zookeeper注册中心，下载地址： http://www.apache.org/dyn/closer.cgi/zookeeper/ 下载后，解压并输入D:\apach-zookeeper-3.4.5\bin，

双击zkServer.cmd启动注册表服务。

2. 定义服务接口: (接口需要单独打包，并在服务提供商和消费者之间共享。)

下面的例子很好。它可以写得非常详细。model.

package com.unj.dubbotest.provider;
import java.util.List;
public interface DemoService {
String sayHello(String name);
public List getUsers();
}

在服务提供商处实现接口：(服务消费者的隐藏实现)

package com.unj.dubbotest.provider;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
public class DemoServiceImpl implements DemoService{
public String sayHello(String name) {
return "Hello " + name;
}
public List getUsers() {
List list = new ArrayList();
User u1 = new User();
u1.setName("jack");
u1.setAge(20);
u1.setSex("男");
User u2 = new User();
u2.setName("tom");
u2.setAge(21);
u2.setSex("女");
User u3 = new User();
u3.setName("rose");
u3.setAge(19);
u3.setSex("女");
list.add(u1);
list.add(u2);
list.add(u3);
return list;
}
}

用Spring配置索赔公开服务：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd
">
<bean id="demoService" class="com.unj.dubbotest.provider.DemoServiceImpl" />
<dubbo:application name="xixi_provider" />
<dubbo:registry address="zookeeper://127.0.0.1:2181" />
<dubbo:protocol name="dubbo" port="20880" />
<dubbo:service interface="com.unj.dubbotest.provider.DemoService" ref="demoService" />

加载Spring配置、启动服务：

package com.unj.dubbotest.provider;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Provider {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"applicationContext.xml"});
context.start();
System.in.read(); // 为了确保服务始终打开，使用输入流的阻塞来模拟
}
}