码迷，mamicode.com
首页 > 其他好文 > 详细

Dubbo

时间：2019-08-18 15:59:21      阅读：94      评论：0      收藏：0      [点我收藏+]

标签：one   artifact   echo   bin   bsp   const   for   bat   负载均衡   

 

1、概念

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

1.1、RPC

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

1.1.1、PRC需要解决的问题

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

1.2、作用

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

 

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
技术图片

 

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”，表示标识该节点。
技术图片

 

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

 

（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。
技术图片

 

（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、项目结构

技术图片

 

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、项目结构

技术图片

 

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

技术图片

 

2.5、创建dubbo-consumer

2.5.1、项目结构

技术图片

 

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原理

技术图片

 

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
技术图片

 

4.4、启动

cd /usr/local/dubbo/dubbo-monitor-simple-2.5.3/bin/
技术图片

 

4.5、访问监控中心

技术图片

 

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
技术图片

 

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
技术图片

 

6、dubbo注解

6.1、dubbo-provider注解实现

6.1.1、添加注解对象

技术图片

 

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

技术图片

 

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

标签：one   artifact   echo   bin   bsp   const   for   bat   负载均衡   

原文地址：https://www.cnblogs.com/aknife/p/11372368.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！