热门关键字：

Dubbo

392
作者：管理员
发布时间：2020/4/20 14:41:19
评论数：0
转载请自觉注明原文：http://www.jq-school.com/Show.aspx?id=1381

1、概念

Dubbo是一个基于java的RPC(Remote Procedure Call)框架。

1.1、RPC

远程过程调用，即在A系统中，远程调用B系统的某个方法或者函数。

1.1.1、PRC需要解决的问题

（1）、通讯问题 （2）、寻址问题 （3）、序列化与反序列化       调用过程中，数据的传输需要先序列化，得到数据进行反序列化。

1.2、作用

在分布式环境下，透明化调用远程方法，就像调用本地方法一样调用远程方法，只需简单配置，没有任何API侵入。 Dubbo

 

2、入门示例

2.1、准备工作

安装dubbo注册中心。推荐使用zookeeper。 作用： （1）存储提供方提供的服务的调用地址。 （2）向调用方提供服务的地址。

2.1.1、Zookeeper

2.1.1.1、概念

ZooKeeper是一个开源的、分布式协调服务。

2.1.1.2、作用

解决分布式应用中经常遇到的一些数据管理问题，简化分布式应用协调及其管理的难度，提供高性能的分布式服务

2.1.1.3、特点

ZooKeeper本身可以以Standalone模式安装运行，不过它的长处在于通过分布式ZooKeeper集群（一个Leader，多个Follower），基于一定的策略来保证ZooKeeper集群的稳定性和可用性，从而实现分布式应用的可靠性。

2.1.2、单节点安装

（1）安装jdk （2）上传安装包到Linux服务器，解压 tar zxvf zookeeper-3.4.10.tar.gz （3）创建配置文件zoo.cfg  zookeeper提供了zoo_sample.cfg这个基础配置文件，直接修改其名称为zoo.cfg 
cd /usr/local/zookeeper/zookeeper-3.4.10/conf
cp zoo_sample.cfg zoo.cfg

 

（4）、启动  ./zkServer.sh start Dubbo

 

2.1.3、集群版安装

2.1.3.1、需求

安装3个zookeeper节点。

2.1.3.2、创建集群目录

  

mkdir -p /usr/local/zkCluster
2.1.3.3、配置一个完整节点 （1）拷贝单节点zookeeper，到集群目录，重命名为zk1 
cp /usr/local/zookeeper/zookeeper-3.4.10 /usr/local/zkCluster/zk1 -rf

 

（2）创建数据文件目录 
mkdir -p /usr/local/zkCluster/zk1/data

 

  （3）在数据文件目录下创建myid文件，并写入值”1”，表示标识该节点。 Dubbo

 

（4）修改zk1的zoo.cfg文件，指定数据文件目录和端口，及集群的配置信息。 Dubbo

 

（5）、复制zk1，一共三份，分别为zk1、zk2、zk3 
cd /usr/local/zkCluster
cp -rf zk1 zk2
cp -rf zk1 zk3

 

  （6）、修改zk2、zk3的myid文件、zoo.cfg文件。 （7）、启动集群 依次启动zk1、zk2、zk3。 Dubbo

 

（8）、自定义shell脚本zkCluster.sh，管理集群启动、关闭、重启操作。 
#!/bin/bash case "$1" in
    start)
        echo 'Starting zkCluster...'
        /usr/local/zkcluster/zk1/bin/zkServer.sh start /usr/local/zkcluster/zk2/bin/zkServer.sh start /usr/local/zkcluster/zk3/bin/zkServer.sh start
        ;;
    stop)
        echo 'Stopping zkCluster...'
        /usr/local/zkcluster/zk1/bin/zkServer.sh stop /usr/local/zkcluster/zk2/bin/zkServer.sh stop /usr/local/zkcluster/zk3/bin/zkServer.sh stop
        ;;
    status) /usr/local/zkcluster/zk1/bin/zkServer.sh status /usr/local/zkcluster/zk2/bin/zkServer.sh status /usr/local/zkcluster/zk3/bin/zkServer.sh status
        ;;
    restart|force-reload)
        echo 'Restarting zkCluster...' ${0} stop
        ${0} start
        ;; *)
esac

 

  （9）、重启集群 
./zkCluster.sh restart

 

  2.1、需求 通过dubbo调用服务，查询用户列表。

2.2、项目结构

dubbo-server:用于添加java接口-interface，定义服务。 dubbo-provider：用于添加java接口实现类，并且发布服务。 dubo-consumer：用于消费服务，即服务的调用。

2.3、创建dubbo-server

2.3.1、项目结构

Dubbo

 

2.3.2、代码实现

（1）、User.java   实现序列化接口 
package cn.gzsxt.dubbo.pojo; import java.io.Serializable; public class User implements Serializable{ /** * */ private static final long serialVersionUID = 4498814071761004317L; private Integer id; private String name; private String pwd; public User() { super(); // TODO Auto-generated constructor stub  } public User(int id, String name, String pwd) { this.id = id; this.name = name; this.pwd = pwd;
    } public Integer getId() { return id;
    } public void setId(Integer id) { this.id = id;
    } public String getName() { return name;
    } public void setName(String name) { this.name = name;
    } public String getPwd() { return pwd;
    } public void setPwd(String pwd) { this.pwd = pwd;
    }
}

 

  （2）UserService.java   定义接口服务 
package cn.gzsxt.dubbo.pojo; import java.io.Serializable; public class User implements Serializable{ /** * */ private static final long serialVersionUID = 4498814071761004317L; private Integer id; private String name; private String pwd; public User() { super(); // TODO Auto-generated constructor stub  } public User(int id, String name, String pwd) { this.id = id; this.name = name; this.pwd = pwd;
    } public Integer getId() { return id;
    } public void setId(Integer id) { this.id = id;
    } public String getName() { return name;
    } public void setName(String name) { this.name = name;
    } public String getPwd() { return pwd;
    } public void setPwd(String pwd) { this.pwd = pwd;
    }
}

 

 

2.4、创建dubbo-provider

2.4.1、项目结构

Dubbo

 

2.4.2、添加pom.xml依赖

  

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>cn.gzsxt.dubbo</groupId> <artifactId>dubbo-provider</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>war</packaging> <dependencies> <!-- 导入dubbo-server服务接口 --> <dependency> <groupId>cn.gzsxt.dubbo</groupId> <artifactId>dubbo-server</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> <!-- dubbo采用spring配置方式，所以需要导入spring容器依赖 --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>4.1.3.RELEASE</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.6.4</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.5.3</version> <exclusions> <exclusion> <!-- 排除传递spring依赖 --> <artifactId>spring</artifactId> <groupId>org.springframework</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.3.3</version> </dependency> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.apache.tomcat.maven</groupId> <artifactId>tomcat7-maven-plugin</artifactId> <version>2.2</version> <configuration> <port>8081</port> <path>/</path> </configuration> </plugin> </plugins> </build> </project>

2.4.3、创建服务实现类

UserServiceImpl.java 
package cn.gzsxt.dubbo.service.impl; import java.util.ArrayList; import java.util.List; import cn.gzsxt.dubbo.pojo.User; import cn.gzsxt.dubbo.service.UserService; /** * UserService服务的实现类
 * @author lyq
 * */ public class UserServiceImpl implements UserService{
    @Override public List<User> getAllUsers() {
         
         List<User> uList = new ArrayList<>();
         
         User user = null; //模拟查询数据库 for(int i =0;i<5;i++){
             user = new User(i,"zs"+i,"gzsxt"+i);
             uList.add(user);
         } return uList;
    }
}

 

 

2.4.4、创建dubbo配置文件dubbo-provider.xml 

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop-4.0.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx-4.0.xsd
http://code.alibabatech.com/schema/dubbohttp://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <!-- 提供方应用信息，用于计算依赖关系 --> <dubbo:application name="dubbo-provider" /> <!-- 这里使用的注册中心是zookeeper --> <dubbo:registry protocol="zookeeper" address="192.168.56.3:2181,192.168.56.3:2182,192.168.56.3:2183" /> <!-- 用dubbo协议在20880端口暴露服务 --> <dubbo:protocol name="dubbo" port="20880" /> <!-- 将具体的实现类加入到Spring容器中 --> <bean id="userServiceImpl" class="cn.gzsxt.dubbo.service.impl.UserServiceImpl" /> <!-- 将服务接口暴露到dubbo中 --> <dubbo:service interface="cn.gzsxt.dubbo.service.UserService" ref="userServiceImpl" /> </beans>

2.4.5、配置Web.xml

  

<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaeehttp://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5"> <display-name>dubbo-provider</display-name> <context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:dubbo/dubbo-*.xml</param-value> </context-param> <!--Spring的ApplicationContext 载入 --> <listener> <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> </listener> <welcome-file-list> <welcome-file>index.jsp</welcome-file> </welcome-file-list> </web-app>

 

 

 

 

2.4.6、启动dubbo-provider

Dubbo

 

2.5、创建dubbo-consumer

2.5.1、项目结构

Dubbo

 

2.5.2、添加pom.xml依赖

  

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>cn.gzsxt.dubbo</groupId> <artifactId>dubbo-consumer</artifactId> <version>0.0.1-SNAPSHOT</version> <dependencies> <!-- 导入dubbo-server服务接口 --> <dependency> <groupId>cn.gzsxt.dubbo</groupId> <artifactId>dubbo-server</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> <!-- dubbo采用spring配置方式，所以需要导入spring容器依赖 --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>4.1.3.RELEASE</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.6.4</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.5.3</version> <exclusions> <exclusion> <!-- 排除传递spring依赖 --> <artifactId>spring</artifactId> <groupId>org.springframework</groupId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.3.3</version> </dependency> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> </dependencies> </project>

 

 

 

 

2.5.3、创建dubbo配置文件dubbo-consumer.xml

  

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop-4.0.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx-4.0.xsd
http://code.alibabatech.com/schema/dubbohttp://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <!-- 提供方应用信息，用于计算依赖关系 --> <dubbo:application name="dubbo-consumer" /> <!-- 这里使用的注册中心是zookeeper --> <dubbo:registry protocol="zookeeper" address="192.168.56.3:2181,192.168.56.3:2182,192.168.56.3:2183" /> <!-- 用dubbo协议在20880端口暴露服务 --> <dubbo:protocol name="dubbo" port="20880" /> <!-- 引用dubbo中的服务 --> <dubbo:reference interface="cn.gzsxt.dubbo.service.UserService" id="userService" /> </beans>

 

 

 

 

2.5.4、本地测试

  

package cn.gzsxt.dubbo.test;
import java.util.List;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import cn.gzsxt.dubbo.pojo.User;
import cn.gzsxt.dubbo.service.UserService;
public class TestConsumer {
    
    @Test
    public void testConsumer(){
         //1.读取配置文件，加载容器
         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:dubbo/dubbo-consumer.xml");
         //2.获取bean对象
         UserService userService = context.getBean("userService", UserService.class);
         //3.调用方法
         List<User> users = userService.getAllUsers();
         System.out.println(users);
    }
}

 

 

 

 

3、dubbo原理

Dubbo

 

0.服务容器负责启动，加载，运行服务提供者。  1.服务提供者在启动时，向注册中心注册自己提供的服务。  2.服务消费者在启动时，向注册中心订阅自己所需的服务。 3.注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。  4.服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。 5.服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

4、安装监控中心

4.1、创建安装目录

mkdir -p /usr/local/dubbo

4.2、上传、解压

tar zxvf dubbo-monitor-simple-2.5.3-assembly.tar.gz -C /usr/local/dubbo

4.3、修改配置文件

cd /usr/local/dubbo/dubbo-monitor-simple-2.5.3/conf
Dubbo

 

4.4、启动

cd /usr/local/dubbo/dubbo-monitor-simple-2.5.3/bin/
Dubbo

 

4.5、访问监控中心

http://192.168.56.3:9090/services.html Dubbo

 

5、安装管理控制台

5.1、解压tomcat、清空tomcat/webapps/ROOT

tar zxvf apache-tomcat-7.0.68.tar.gz -C /usr/local/dubbo rm /usr/local/dubbo/apache-tomcat-7.0.68/webapps/ROOT/* -rf

5.2、解压dubbo-admin.war至tomcat/webapps/ROOT目录

unzip dubbo-admin-2.5.4.war -d /usr/local/dubbo/ tomcat-7.0.68/webaaps/Root

5.3、修改dubbo.properties

cd /usr/local/dubbo/apache-tomcat-7.0.68/webapps/ROOT/WEB-INF
Dubbo

 

5.4、启动tomcat

cd /usr/local/dubbo/apache-tomcat-7.0.68/bin  && ./startup.sh

5.5、访问控制台

http:192.168.56.3:8080/governance/services Dubbo

 

6、dubbo注解

6.1、dubbo-provider注解实现

6.1.1、添加注解对象

Dubbo

 

6.1.2、修改dubbo-provider.xml配置，开启注解

Dubbo

 

6.2、dubbo-consumer注解实现

6.2.1、新增spring-test依赖

<!-- 导入spring-test的依赖 -->        <dependency>            <groupId>org.springframework</groupId>            <artifactId>spring-test</artifactId>            <version>4.1.3.RELEASE</version>        </dependency>                <dependency>            <groupId>junit</groupId>            <artifactId>junit</artifactId>            <version>4.12</version>        </dependency>

6.2.2、修改测试类

@RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration(locations="classpath:dubbo/dubbo-consumer.xml") public class TestConsumer {     @Reference     private UserService userService;          @Test     public void testConsumer(){             List<User> users = userService.getAllUsers();        System.out.println(users);     } }

6.2.3、修改dubbo-consumer.xml，开启注解

Dubbo



如果您觉得本文的内容对您的学习有所帮助：支付鼓励



关键字：Dubbo
友荐云推荐