java 零基础搭建dubbo运行环境

一：简介

　　    之前作项目时，分布式环境都是其它同事在搭建，本身也没参与分布式环境搭建，只负责开发，因为近段时间工做重心转到android，java后台有一段时间没有接触了，恰好这几天有空，决定本身动手亲自搭建一次spring+dubbo+zookeeper的运行环境,方便之后在工做中使用，若有描述错误的地方，请指正，谢谢。

　　   1 dubbo描述

　　　Dubbo是一个分布式服务框架，若是是一个小的erp系统，一台服务器足够支撑项目运行，项目就不会用Dubbo，若是是一个大的商城项目，用户访问量比较大，一台没法器根本没法支撑运行时，咱们能够把订单模块，支付模块，静态页面等独立出来，放置在同一个局域网，不一样服务器运行，这时咱们就须要使用Dubbo, Dubbo原理图以下：

　　　　　

    节点角色说明：

Provider: 暴露服务的服务提供方，好比支付系统实现支付接口，供订单系统调用

Consumer: 调用远程服务的服务消费方，好比订单系统调用支付系统提供的服务进行付款操做。

        Registry: 服务注册与发现的注册中心。

        Monitor: 统计服务的调用次调和调用时间的监控中心。

        Container: 服务运行容器。

    各个角色之间的调用关系：

        1 服务容器负责启动，加载，运行服务提供者。2 服务提供者在启动时，向注册中心注册本身提供的服务。3 服务消费者在启动时，向注册中心订阅本身所需的服务。4注册中心返回服务提供者地址列表给消费者，若是有变动，注册中心将基于长链接推送变动数据给消费者。5 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，若是调用失败，再选另外一台调用。6 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心(此段描述来自网络)。

　　2 zookeeper下载地址,http://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.3.6/   下载后直接解压便可

二：环境搭建

　　1 测试环境

         我本地测试环境是 Window 7 64,Eclipse 4.4,jdk1.8,tomcat 8,zookeeper-3.3.6,apache-maven-3.5.0

        2 建立项目

         如今咱们模拟一个商城环境，将支付模块和订单模块独立出来，在不一样服务器上运行，而后相互以前调用，因为两个系统须要相互调用，即支付模块是服务提供者，又是消费者，订单模块也是服务提供者，又是消费者.

        建立父工程shopping,建立完成后，设置父工程的Packaging为pom

　　

　　　　建立子工程,shopping-api(用于定义公共接口，公共实体类等),shopping-order(订单模块，须要依赖shopping-api,实现订单的service接口),shopping-pay(订单模块，须要依赖shopping-api,实现支付的service接口).

 

　　3：service的定义及实现

　　全部接口定义在shopping-api中，订单接口定义以下：

//定义订单读接口
package com.service.order;

import java.util.List;
import com.bean.OrderBean;
/**
 * 订单查询
 * */
public interface OrderReadService {
    List<OrderBean> listQuery();
    OrderBean getOrder(long oId);
}

      支付接口定义以下：

package com.service.pay;

/**
 * 订单支付
 * */
public interface PayService {
    String pay(long orderId); 
}

订单接口须要在shopping-order项目中实现，代码以下:

package com.order.impl;

import java.util.List;
import java.util.Random;
import java.util.Vector;

import com.bean.OrderBean;
import com.service.order.OrderReadService;
  
/**
 * 订单查询实现类
 * */
public class OrderReadServiceImpl implements OrderReadService {

    @Override
    public List<OrderBean> listQuery() {
        // TODO Auto-generated method stub
        List<OrderBean> list = new Vector<OrderBean>();
        for(int i=0;i<5;i++){
            OrderBean bean = new OrderBean();
            bean.setoId(i+10);
            bean.setoMoney(100+new Random().nextInt(50));
            bean.setoUserId(500+new Random().nextInt(50));
            list.add(bean);
        }
        return list;
    }

    @Override
    public OrderBean getOrder(long oId) {
        // TODO Auto-generated method stub
        OrderBean bean = new OrderBean();
        bean.setoId(oId);
        bean.setoMoney(100+new Random().nextInt(50));
        bean.setoUserId(500+new Random().nextInt(50));
        return bean;
    }

}

　支付接口须要在shopping-pay项目中实现，代码以下：

package com.pay.impl;

import com.service.pay.PayService;
 

public class PayServiceImpl implements PayService {

    @Override
    public String pay(long orderId) {
        // TODO Auto-generated method stub
        return orderId + "支付成功.";
    }

}

　　4:项目之间的依赖关系

　　因为shopping-api定义了完整的接口，shopping-order,shopping-pay实现了shopping-api项目下的接口，因此须要在shopping-order,shopping-pay项目中配置依赖关系，代码以下：

<dependency>
        <groupId>shopping-api</groupId>
        <artifactId>shopping-api</artifactId>
        <version>0.0.1-SNAPSHOT</version>
</dependency>

　　5:配置Dubbo提供者和消费者的xml

　　因为两个项目以前须要相互调用，因此两个项目都须要配置服务提供者，和消费者，代码以下：

　　shopping-order订单项目的xml配置以下：

<!--定义了提供方应用信息，用于计算依赖关系；在 dubbo-admin 或 dubbo-monitor 会显示这个名字，方便辨识 -->
<dubbo:application name="shopping-order" owner="programmer" organization="dubbox" />
<!--向 zookeeper 订阅 provider 的地址，由 zookeeper 定时推送 -->
<dubbo:registry address="zookeeper://localhost:2181" check="false"/>
<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol name="dubbo" port="20880" />

<!-- (配置订单服务提供者 )提供支付方的接口 -->
<dubbo:service ref="orderReadService" protocol="dubbo" interface="com.service.order.OrderReadService"></dubbo:service>
<bean id="orderReadService" class="com.order.impl.OrderReadServiceImpl"></bean>
<dubbo:service ref="orderWriterService" protocol="dubbo" interface="com.service.order.OrderWriterService"></dubbo:service>
<bean id="orderWriterService" class="com.order.impl.OrderWriterServiceImpl"></bean>

<!-- 配置消费者 --> 
<!--使用 dubbo 协议调用定义好的 api.PermissionService 接口 -->
<dubbo:reference id="payService" interface="com.service.pay.PayService" check="false"></dubbo:reference>

 

 　shopping-pay支付项目的xml配置以下：

　　<!--定义了提供方应用信息，用于计算依赖关系；在 dubbo-admin 或 dubbo-monitor 会显示这个名字，方便辨识 -->
    <dubbo:application name="shopping-pay" owner="programmer" organization="dubbox" />
    <!--向 zookeeper 订阅 provider 的地址，由 zookeeper 定时推送 -->
    <dubbo:registry address="zookeeper://localhost:2181"  check="false" />
    <!-- 用dubbo协议在20880端口暴露服务,因为订单设置的端口是20880，此处设置20881，否则tomcat启动后，会冲突报错 -->
    <dubbo:protocol name="dubbo" port="20881" />
    
    <!-- (配置支付服务提供者)提供给订单项目调用 -->
    <dubbo:service interface="com.service.pay.PayService"  ref="payService" protocol="dubbo"></dubbo:service>
    <bean id="payService" class="com.pay.impl.PayServiceImpl"></bean>
    
    
    <!-- (配置消费者) -->
    <dubbo:reference interface="com.service.order.OrderReadService" id="orderReadService"></dubbo:reference>
    <dubbo:reference interface="com.service.order.OrderWriterService" id="orderWriterService"></dubbo:reference>

 

三：建立tomcat运行环境

　　    我将不一样的项目，放置在不一样的tomcat下，建立过程：File-new-Other,弹出以下窗体

　　　　

 

　　　　

 

　　添加完成，将项目导入tomcat，效果图以下

　　shopping-pay将端口号设置为：8081,

　　

　　　shopping-order将端口号设置为：8082

 　　

　　

四：启动项目，调用接口测试

　　启动tomcat前，须要先启动zookeeper,先进入以前解压的zookeeper/bin目录，运行zkServer.cmd，而后再启动tomcat，两个项目不分前后启动，但测试前，须要保证两个项目正常启动.

　　直接在浏览器中输入以下地址测试,控制层的代码，没有贴出来，完整代码在文章最后有下载地址：

http://127.0.0.1:8081/shopping-pay/pay/orderList.do?id=10

http://127.0.0.1:8082/shopping-order/order/pay.do?id=123

五：注意事项

 　　由于两个项目，须要相互调用，因此配置服务端口暴露服务时，记得将两个端口设置为不同，否则会出错，此处配置我也不是很熟悉，如配置不对，请指正，谢谢，配置以下：

<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol name="dubbo" port="20880" />

<!-- 用dubbo协议在20880端口暴露服务,因为订单设置的端口是20880，此处设置20881，否则tomcat启动后，会冲突报错 -->
<dubbo:protocol name="dubbo" port="20881" />

　　另外还须要注意：向 zookeeper 订阅 provider 的地址,以及配置dubbo:service，须要把check设置为false,否则项目没法启动，

　　

<dubbo:registry address="zookeeper://localhost:2181"  check="false" />

<dubbo:service interface="com.service.pay.PayService"  ref="payService" protocol="dubbo"></dubbo:service>

        因为两个项目依赖于，shopping-api，虽然在pom.xml中引入了对shopping-api的依赖，我本地tomcat启动时，仍然报错，找不到shopping-api下的公共类，因此我将shopping-api打包成jar包，放置在shopping-order和shopping-pay项目中。

 

参考文献：

分布式系统架构实战demo:SSM+Dubbo
https://my.oschina.net/liughDevelop/blog/1480061#0-sqq-1-469-9737f6f9e09dfaf5d3fd14d775bfee85

dubbo 既是提供方又是消费方的问题
https://blog.csdn.net/q596333033/article/details/78573741

Dubbo架构

http://dubbo.apache.org/books/dubbo-dev-book/design.html

 dubbo 知识总结 dubbo配置参考

https://blog.csdn.net/abcde474524573/article/details/53026110

 

 这是本人第一次搭建dubbo环境，本文可能有错误的地方，但愿你们指正，谢谢，完整代码下载地址：https://github.com/jlq023/dubbo-shopping