dubbo

分布式

发布日期: 2019-06-13

文章字数: 2.4k

阅读时长: 12 分

阅读次数:

dubbo环境搭建

安装zookeeper

下载zookeeper

Index of /dist/zookeeper/zookeeper-3.4.13

解压

1560396996149

修改配置文件

进入C:\Users\shenlibing\Downloads\zookeeper-3.4.13\conf将conf下的zoo_sample.cfg复制一份改名为zoo.cfg即可

1560406178201

dataDir 临时数据存储的目录（可写相对路径）
clientPort=2181 zookeeper的端口号

1560396968926

测试

1560406513211

开启服务端

1560397123787

开启客户端

1560406459868

安装dubbo-admin管理控制台

dubbo本身并不是一个服务软件。它其实就是一个jar包能够帮你的java程序连接到zookeeper，并利用zookeeper消费、提供服务。

但是为了让用户更好的管理监控众多的dubbo服务，官方提供了一个可视化的监控程序，不过这个监控即使不装也不影响使用。

下载dubbo-admin

apache/dubbo-admin at master

1560406775445

解压

1560407418522

修改dubbo-admin配置

1560407528940

指定zookeeper地址

1560407565437

打包dubbo-admin

mvn clean package -Dmaven.test.skip=true

1560407882961

运行dubbo-admin

java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

1560407980878

1560408182379

访问

http://localhost:7001，默认使用`root/root `登陆

1560408254046

dubbo-helloworld

创建订单服务web模块

1560412993991

1560413153432

用户服务service模块

1560412993991

1560413103016

分包

版本一

order-service-consumer订单消费层
user-service-provider用户服务提供层

1560413314279

版本二

将公共的地址实体、订单接口、用户接口提取到公共接口层，新建一个公共接口层

1560413460737

gmall-interface公共接口层
order-service-consumer订单消费层
user-service-provider用户服务提供层

1560413803648

代码

公共接口层代码

UserAddress.java

package com.atguigu.gmall.bean;

import java.io.Serializable;

/**
 * 用户地址
 * @author lfy
 *
 */
public class UserAddress implements Serializable {

    private Integer id;
    private String userAddress; //用户地址
    private String userId; //用户id
    private String consignee; //收货人
    private String phoneNum; //电话号码
    private String isDefault; //是否为默认地址    Y-是     N-否

    public UserAddress() {
        super();
        // TODO Auto-generated constructor stub
    }

    public UserAddress(Integer id, String userAddress, String userId, String consignee, String phoneNum,
            String isDefault) {
        super();
        this.id = id;
        this.userAddress = userAddress;
        this.userId = userId;
        this.consignee = consignee;
        this.phoneNum = phoneNum;
        this.isDefault = isDefault;
    }

    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getUserAddress() {
        return userAddress;
    }
    public void setUserAddress(String userAddress) {
        this.userAddress = userAddress;
    }
    public String getUserId() {
        return userId;
    }
    public void setUserId(String userId) {
        this.userId = userId;
    }
    public String getConsignee() {
        return consignee;
    }
    public void setConsignee(String consignee) {
        this.consignee = consignee;
    }
    public String getPhoneNum() {
        return phoneNum;
    }
    public void setPhoneNum(String phoneNum) {
        this.phoneNum = phoneNum;
    }
    public String getIsDefault() {
        return isDefault;
    }
    public void setIsDefault(String isDefault) {
        this.isDefault = isDefault;
    }

}

OrderService.java

package com.atguigu.gmall.service;

import java.util.List;

import com.atguigu.gmall.bean.UserAddress;

public interface OrderService {

    /**
     * 初始化订单
     * @param userId
     */
    public List<UserAddress> initOrder(String userId);

}

UserService.java

package com.atguigu.gmall.service;

import java.util.List;

import com.atguigu.gmall.bean.UserAddress;

/**
 * 用户服务
 * @author lfy
 *
 */
public interface UserService {

    /**
     * 按照用户id返回所有的收货地址
     * @param userId
     * @return
     */
    public List<UserAddress> getUserAddressList(String userId);

}

订单消费层代码

OrderServiceImpl.java

package com.atguigu.gmall.service.impl;

import java.util.List;

import com.atguigu.gmall.bean.UserAddress;
import com.atguigu.gmall.service.OrderService;
import com.atguigu.gmall.service.UserService;

/**
 * 1、将服务提供者注册到注册中心（暴露服务）
 *         1）、导入dubbo依赖（2.6.2）\操作zookeeper的客户端(curator)
 *         2）、配置服务提供者
 * 
 * 2、让服务消费者去注册中心订阅服务提供者的服务地址
 * @author lfy
 *
 */
public class OrderServiceImpl implements OrderService {

    UserService userService;
    @Override
    public List<UserAddress> initOrder(String userId) {
        // TODO Auto-generated method stub
        System.out.println("用户id："+userId);
        //1、查询用户的收货地址
        List<UserAddress> addressList = userService.getUserAddressList(userId);
        for (UserAddress userAddress : addressList) {
            System.out.println(userAddress.getUserAddress());
        }
        return addressList;
    }



}

用户服务提供层代码

UserServiceImpl.java

package com.atguigu.gmall.service.impl;

import java.util.Arrays;
import java.util.List;

import com.atguigu.gmall.bean.UserAddress;
import com.atguigu.gmall.service.UserService;

public class UserServiceImpl implements UserService {

    @Override
    public List<UserAddress> getUserAddressList(String userId) {
        UserAddress address1 = new UserAddress(1, "北京市昌平区宏福科技园综合楼3层", "1", "李老师", "010-56253825", "Y");
        UserAddress address2 = new UserAddress(2, "深圳市宝安区西部硅谷大厦B座3层（深圳分校）", "1", "王老师", "010-56253825", "N");
        return Arrays.asList(address1,address2);
    }

}

依赖配置

订单消费层需要引用公共接口层

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.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.atguigu.gmall</groupId>
  <artifactId>order-service-consumer</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <dependencies>
  <dependency>
      <groupId>com.atguigu.gmall</groupId>
      <artifactId>gmall-interface</artifactId>
      <version>0.0.1-SNAPSHOT</version>
  </dependency>
  </dependencies>
</project>

用户服务提供层需要引用公共接口层

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.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.atguigu.gmall</groupId>
  <artifactId>user-service-provider</artifactId>
  <version>0.0.1-SNAPSHOT</version>

  <dependencies>
      <dependency>
          <groupId>com.atguigu.gmall</groupId>
          <artifactId>gmall-interface</artifactId>
          <version>0.0.1-SNAPSHOT</version>
      </dependency>
  </dependencies>
</project>

dubbo通信

为了让订单消费层和用户服务提供层可以通信，使用dubbo进行配置

用户服务提供层

导入依赖

导入dubbo依赖（2.6.2）
操作zookeeper的客户端(curator)依赖

<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.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.atguigu.gmall</groupId>
  <artifactId>user-service-provider</artifactId>
  <version>0.0.1-SNAPSHOT</version>

  <dependencies>
      <dependency>
          <groupId>com.atguigu.gmall</groupId>
          <artifactId>gmall-interface</artifactId>
          <version>0.0.1-SNAPSHOT</version>
      </dependency>

    <!-- 引入dubbo -->
    <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.6.2</version>
    </dependency>
    <!-- 注册中心使用的是zookeeper，引入操作zookeeper的客户端端 -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>2.12.0</version>
    </dependency>

  </dependencies>
</project>

配置服务提供者

新建provider.xml文件

1560416196643

指定当前服务/应用的名字
指定注册中心的位置
指定通信规则（通信协议？通信端口）
暴露服务

provider.xml

<?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://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!-- 1、指定当前服务/应用的名字（同样的服务名字相同，不要和别的服务同名） -->
    <dubbo:application name="user-service-provider"></dubbo:application>

    <!-- 2、指定注册中心的位置 -->
    <!-- <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry> -->
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>

    <!-- 3、指定通信规则（通信协议？通信端口） -->
    <dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>

    <!-- 4、暴露服务   ref：指向服务的真正的实现对象 -->
    <dubbo:service interface="com.atguigu.gmall.service.UserService" 
        ref="userServiceImpl">
    </dubbo:service>

    <!-- 服务的实现 -->
    <bean id="userServiceImpl" class="com.atguigu.gmall.service.impl.UserServiceImpl"></bean>

</beans>

测试服务提供者

新建MainApplication.java

1560416741955

MainApplication.java

package com.atguigu.gmall;

import java.io.IOException;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class MainApplication {

    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("provider.xml");
        ioc.start();

        System.in.read();
    }

}

在dubbo控制台进行查看,可以看到有一个服务提供者

1560416905173

1560416842863

1560416860686

订单消费层

导入依赖

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.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <groupId>com.atguigu.gmall</groupId>
  <artifactId>order-service-consumer</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <dependencies>
      <dependency>
          <groupId>com.atguigu.gmall</groupId>
          <artifactId>gmall-interface</artifactId>
          <version>0.0.1-SNAPSHOT</version>
      </dependency>

      <!-- 引入dubbo -->
        <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.2</version>
        </dependency>
        <!-- 注册中心使用的是zookeeper，引入操作zookeeper的客户端端 -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>

  </dependencies>
</project>

配置订单消费者

新建consumer.xml文件

1560417509618

consumer.xml

<?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://dubbo.apache.org/schema/dubbo"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
        http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <context:component-scan base-package="com.atguigu.gmall.service.impl"></context:component-scan>


    <dubbo:application name="order-service-consumer"></dubbo:application>

    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>


    <!--声明需要调用的远程服务的接口；生成远程服务代理  -->
    <dubbo:reference interface="com.atguigu.gmall.service.UserService" 
        id="userService">
    </dubbo:reference>

</beans>

测试订单消费者

新建MainApplication.java

1560417802317

MainApplication.java

package com.atguigu.gmall;

import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.atguigu.gmall.service.OrderService;

public class MainApplication {

    @SuppressWarnings("resource")
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");

        OrderService orderService = applicationContext.getBean(OrderService.class);

        orderService.initOrder("1");
        System.out.println("调用完成....");
        System.in.read();
    }

}

运行MainApplication.java

1560417933975

扫描订单消费层

1560494281945

修改订单消费代码，将消费实现加入到容器，并把UserService注入进来

1560418003061

查看dubbo控制台，服务数：1，应用数：2，提供者数：1，消费者数：1

1560418137215

安装dubbo-monitor-simple

简单的监控中心

下载

apache/dubbo-admin at master

1560495820794

解压

1560495743361

修改配置文件

进入C:\Users\shenlibing\Downloads\dubbo-admin-master\dubbo-monitor-simple\src\main\resources\conf目录，编辑dubbo.properties

1560496227527

1560496200232

打包

mvn clean package -Dmaven.test.skip=true

1560496299065

解压

解压dubbo-monitor-simple-2.0.0-assembly.tar.gz—>dubbo-monitor-simple-2.0.0-assembly.tar—>dubbo-monitor-simple-2.0.0

1560496424160

运行

1560496611658

1560496620775

访问

http://localhost:8080,如下图所示

1560496776113

转载规则

《dubbo》由 shenlibing 采用知识共享署名 4.0 国际许可协议进行许可。

SpringData

spring整合hibernate、hibernate jpa，springdata jpa的使用，springdata Redis安装、整合

2019-06-15 框架

springdata

mysql

mysql的安装使用、多表查询索引优化、底层的存储引擎分类、慢SQL的定位解决思路

2019-06-08 数据库

mysql

dubbo环境搭建

安装zookeeper

下载zookeeper

解压

修改配置文件

测试

开启服务端

开启客户端

安装dubbo-admin管理控制台

下载dubbo-admin

解压

修改dubbo-admin配置

打包dubbo-admin

运行dubbo-admin

访问

dubbo-helloworld

创建订单服务web模块

用户服务service模块

分包

版本一

版本二

代码

公共接口层代码

订单消费层代码

用户服务提供层代码

依赖配置

dubbo通信

用户服务提供层

导入依赖

配置服务提供者

测试服务提供者

订单消费层

导入依赖

配置订单消费者

测试订单消费者

安装dubbo-monitor-simple

下载

解压

修改配置文件

打包

解压

运行

访问

你的赏识是我前进的动力