Dubbo学习笔记

1 dubbo的 作用
以下内容摘自dubbo官网：
　　dubbo是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现;

2 查看官网大坑

　　(二)dubbo管理控制台的搭建

git clone https://github.com/apache/incubator-dubbo-ops

cd incubator-dubbo-ops && mvn package

用法，分为三个 admin, register/ monitor
dubbo admin

Dubbo admin is a spring boot application, you can start it with fat jar or in IDE directly.

进入 dubbo-admin,执行 mvn install
-----------------------------
maven 下载打包时需要配置 仓库MAVEN_HOME,Path=xxxxxj,这样的话就会用配置的阿里云镜像，下载会很快
碰到了不能编译，需要配置java环境变量
编译后启动报错了，因为没改zookeeper的配置ip,重新安装打包，运行target下的 java -jar dubbo-xxxxxx.jar，账号参考配置里的 root/root 或者 guest/xxxx,端口查看配置 时 7001

dubbo monitor and dubbo registry
You can get a release of dubbo monitor in two steps:

Step 1:
git clone https://github.com/apache/incubator-dubbo-ops
Step 2:
cd incubator-dubbo-ops && mvn package
Then you will find:

dubbo-monitor-simple-2.0.0-assembly.tar.gz in incubator-dubbo-opsdubbo-monitor-simple arget directory. Unzip it you will find the shell scripts for starting or stopping monitor.
dubbo-registry-simple-2.0.0-assembly.tar.gz in incubator-dubbo-opsdubbo-registry-simple arget directory. Unzip it you will find the shell scripts for starting or stopping registry.

 

2 然后时健康检测项目，打包，改zookeeperip，解压生成的 target下的 xxx.gz,进入 assembly.bin，运行start.bat即可

F:programmedubbo-admin-masterdubbo-monitor-simple argetdubbo-monitor-simple-2.0.0assembly.bin

 

bat启动文件 

f:
cd F:programmedubbo-admin-masterdubbo-admin arget
java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

f:
cd F:programmedubbo-admin-masterdubbo-monitor-simple argetdubbo-monitor-simple-2.0.0assembly.bin
start.bat

4 自动生成 serializable 方法的配置再idea中

4 真实的 测试dubbo的例子

/**
 * 订单服务相关接口
 */
public interface OrderService {
    
    /**
     * 初始化订单
     * @param userId
     */
    List<User> initOrder(String userId);

}


public interface UserService {

    /**
     * 获取用户信息
     * @param userId
     * @return
     */
    List<User> getUserList(String userId);
    List<User> getUserAddressList(String userId);
}


user-service-provider
     <dependency>
            <groupId>com.darling.dubboDemo</groupId>
            <artifactId>pub-interfence</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

            <!-- 引入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>



package com.provider.userserviceprovider.service;

import com.pubinter.pubinterface.dao.UserService;
import com.pubinter.pubinterface.pojo.User;

import java.util.ArrayList;
import java.util.List;

public class UserServiceImpl implements UserService {


    public List<User> getUserAddressList(String userId) {
        List<User> list = new ArrayList();
        list.add(new User(3,"韦德",36,"迈阿密"));
        list.add(new User(23,"詹姆斯",34,"洛杉矶"));
        list.add(new User(24,"科比",39,"洛杉矶"));
        return list;
    }

    @Override
    public List<User> getUserList(String userId) {
        return null;
    }
}


<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <!-- 当前服务的名称 -->
    <dubbo:application name="user-service-provider"/>

    <!-- 注册中心的地址 这里注册中心用的是zookeeper -->
    <dubbo:registry protocol="zookeeper" address="148.70.4.44:2181"/>

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

    <!-- 需要暴露的服务 -->
    <dubbo:service interface="com.pubinter.pubinterface.dao.UserService" ref="userService" version="1.0.0"/>

    <!-- 需要暴露的服务的实现类 -->
    <bean id="userService" class="com.provider.userserviceprovider.service.UserServiceImpl"/>

    <!-- 监控中心协议，如果为protocol="registry"，表示从注册中心发现监控中心地址，否则直连监控中心 -->
    <dubbo:monitor protocol="registry"></dubbo:monitor>

    <!--
        timeout：超时时间配置
        retries：重试次数配置(超时报错后重试连接的次数,不含第一次调用,如果目标服务有多个重试的时候会自动切换别的服务)
     -->
    <dubbo:provider timeout="2000" retries="6"></dubbo:provider>
</beans>


public class TestProviderDemo {

    public static void main(String[] args) throws IOException {
        // 加载配置文件
        ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("provider.xml");
        // 容器启动
        applicationContext.start();
        // 使程序阻塞(由于是单元测试,如果程序跑完了我们再dubbo控制台看不到效果)
        System.in.read();
    }
}


不启用spring boot 主类，因为没必要，只启动了这个一个配置文件
order-service-consumer

      <!-- 引入公共接口层的依赖 -->
        <dependency>
            <groupId>com.darling.dubboDemo</groupId>
            <artifactId>pub-interfence</artifactId>
            <version>1.0-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>


    /**
 *   @author 董琳琳
 *   @date 2018/9/14 11:50
 *   @description   订单服务的实现类
 */
@Service
public class OrderServiceImpl implements OrderService {

    @Autowired
    UserService userService;

    /**
     * 初始化订单并调用用户服务的接口
     * @param userId
     * @return
     */
    @Override
    public List<User> initOrder(String userId) {
        return userService.getUserAddressList(userId);
    }
}


<?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">
    <!-- 开启springmvc的包扫描 -->
    <context:component-scan base-package="com.order.orderserviceconsumer"></context:component-scan>
    <!-- 当前服务的名称 -->
    <dubbo:application name="order-service-consumer"/>

    <!-- 注册中心的地址 这里注册中心用的是zookeeper -->
    <dubbo:registry protocol="zookeeper" address="148.70.4.44:2181"/>

    <!-- 声明需要调用的远程服务的接口；生成远程服务代理 -->
    <dubbo:reference id="userService" check="false" interface="com.pubinter.pubinterface.dao.UserService" version="*"/>

    <!-- 监控中心协议，如果为protocol="registry"，表示从注册中心发现监控中心地址，否则直连监控中心 -->
    <dubbo:monitor protocol="registry"></dubbo:monitor>
</beans>

user必须实现serializable接口


必须要加扫描路径，不然会出错，找不到类
    <context:component-scan base-package="com.darling.order"></context:component-scan>

/**
 *   @author 董琳琳
 *   @date 2018/9/14 15:57
 *   @description 测试服务调用者是否成功从注册中心订阅服务
 */
public class TestConsumerDemo {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
        OrderService service = applicationContext.getBean(OrderService.class);
        List<User> list = service.initOrder("1");
        for (User user:list) {
            System.out.println(user.toString());
        }
        System.in.read();
    }
}


import java.io.Serializable;

public class User implements Serializable {
    private static final long serialVersionUID = -2844400681715908324L;
    private int age;
    private String name;
    private String address;
    private int number;
    User(){};
    public User(int age,String name,int number,String address){
        this.address=address;
        this.age=age;
        this.number=number;
        this.name=name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getAddress() {
        return address;
    }

    public void setAddress(String address) {
        this.address = address;
    }

    public int getNumber() {
        return number;
    }

    public void setNumber(int number) {
        this.number = number;
    }
}

  大概流程是，public 接口，有两个，一个user 类，需要实现serializable接口和 set get方法，第二个项目provider引入公共的刚才的想pub，进行生产者配置，第三个消费者配置，兜售ideal 项目的module方式，

最终的效果是

5 dubbo 2.5版本 telnet命令

 

默认是 22222,可用通过 dubbo.properties修改为
dubbo.application.qos.port=33333
或启动时修改
-Ddubbo.application.qos.port=33333
安全方面 ，谁都可以访问，可以关闭，这样远程的就不可访问
dubbo.application.qos.accept.foreign.ip=false

举例
telnet localhost 22222
接口方式访问

curl "localhost:22222/ls?arg1=xxx&arg2=xxxx"

常用命令：
ls 可查看producer和consumer两个角色信息
online 上线所有的服务，可以正则
online xxx.com 上线某种服务
需要下线后重新上线时采用的场景

下线命令
offline 和 online 用法一样
help 查看帮助，这个很简单 telnet 功能，默认系统配置

-Ddubbo.application.qos.enable=true
-Ddubbo.application.qos.port=33333
-Ddubbo.application.qos.accept.foreign.ip=false

1 docker 使用Dockerfile 构建镜像
例子 只两行
FROM nginx
RUN echo 'abc' > /usr/nginx/index.html

from指定从nginx作为基础版本
run 是执行 linux命令

内容两行

执行一条命令 构建
docker build -他nginx:my .

在当前路径构建，点是当前路径，后面的是名字

执行一条命令运行
docker -d -p 11:80

浏览器打开 xxx:11 结果是自己写的命令输入的内容，所以自己的 镜像构建成功了

docker 的命令15个太多了

2 使用maven 插件打包发布程序为新 镜像分三步，1 是 加maven依赖 配置，
包括了 imagename镜像名 ，包括了 仓库名，镜像名，标签用冒号，2 entrypoint 表示执行的命令
baseimage 就是 from 基于java的 都是
同时引入了 resource.resource.include 表示引入了 拷贝xxx.jar
第二步是 构建，第三步是 运行，就可以查看到了 镜像和容器

 3 然后更加专业的写法，baseimage和  enpoint 都不在pom里，而在 Dockerfile文件里，在 pom只指定一个目录就行了，这样是生产环境专业的写法

 4   最终 自己建立的docker 镜像 会推送到  docker hub中，或者是个人仓库中，

可以用maven也可以用push命令，push命令还没有用过，下面例子是maven：

如果是 hub中心则 在maven的server 中配置 id，hub的 用户名，hub的密码

也可以私有镜像，但需要 baseImage中设置 localhost:5000 xxxxxxxxx