SpringBoot整合Dubbo

前期准备:下载安装zookeeper作为服务注册中心

安装步骤

• 解压

tar zxvf zookeeper-3.4.8.tar.gz

• 将zoo_sample.cfg文件名修改为zoo.cfg，并修改配置文件中的内容。
  默认为zoo.cfg，可以查看zookeeper-3.4.6\bin\zkEnv.cmd

dataDir=C:\\Users\\tianthe\\zk\\data
dataLogDir=C:\\Users\\tianthe\\zk\\log

修改数据存放的文件目录，并添加了存放日志文件的文件目录

• 启动zookeeper

cd zookeeper-3.3.6
cd bin
./zkServer.sh start

附：zookeeper下载地址

服务提供者

• 项目结构

  
  provider结构图.png

• 依赖

<dependencies>
        <!-- Spring Boot Dubbo -->
        <dependency>
            <groupId>io.dubbo.springboot</groupId>
            <artifactId>spring-boot-starter-dubbo</artifactId>
            <version>1.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.2</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

• 公共api:helloDubboService.java

public interface HelloDubboService {
    String helloDubbo();
}

• 公共api的实现类

@Service
public class HelloDubboServiceImpl implements HelloDubboService {
    @Override
    public String helloDubbo() {
        return "hello dubbo";
    }
}

@Service注解导入的包为com.alibaba.dubbo.config.annotation.Service;，通过这个注解将这个类申明为dubbo服务

• 配置文件:application.properties

server.port=8080

## Dubbo 服务消费者配置
spring.dubbo.application.name=consumer
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=20880
spring.dubbo.scan=com.cqupt.dubbo.service
## 数据源配置
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/shop?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowMultiQueries=true
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

spring.dubbo.application.name:应用名称
spring.dubbo.registry.address:注册地址
spring.dubbo.protocol.name:协议名称
spring.dubbo.protocol.port:协议端口
spring.dubbo.scan:扫描的包
只有服务提供者配置文件中需要配置spring.dubbo.protocol.name和spring.dubbo.protocol.port，服务消费者不需要

服务调用者

• 项目结构

  
  Consumer结构图.png

• 依赖
  和服务提供者差不多

• 公共api的实现类

@Service
public class HelloDubboServiceImpl implements HelloDubboService {
    @Override
    public String helloDubbo() {
        return "hello dubbo";
    }
}

• 控制类:HelloDubboController .java

@RestController
public class HelloDubboController {
    @Reference
    private HelloDubboService helloDubboService;

    @RequestMapping("/hello")
    public String helloDubbo() {
        return helloDubboService.helloDubbo();
    }
}

• 配置文件:application.properties

server.port=8081

## Dubbo 服务消费者配置
spring.dubbo.application.name=consumer
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.scan=com.cqupt.dubbo.service

服务提供者和服务调用者公用一份api，一种是将公共api写到独立的项目中，并生成一个依赖。另外一种是每个项目中都写这个公共api，其中服务提供者需要实现公共api，而服务调用者只需写公共api即可
该项目的公共api为:helloDubboService

启动

1.启动zookeeper
2.启动SpringBoot-Dubbo-Provider
3.启动SpringBoot-Dubbo-Consumer
启动服务提供者和服务调用者时，只有都出现：

zookeeper state changed (SyncConnected)
[DUBBO] Register: consumer://192.168.1.103/com.cqupt.dubbo.service.HelloDubboService?application=consumer&category=consumers&check=false&dubbo=2.5.3&interface=com.cqupt.dubbo.service.HelloDubboService&methods=helloDubbo&pid=18968&side=consumer&timestamp=1524742106566, dubbo version: 2.5.3, current host: 192.168.1.103
[DUBBO] Subscribe: consumer://192.168.1.103/com.cqupt.dubbo.service.HelloDubboService?application=consumer&category=providers,configurators,routers&dubbo=2.5.3&interface=com.cqupt.dubbo.service.HelloDubboService&methods=helloDubbo&pid=18968&side=consumer&timestamp=1524742106566, dubbo version: 2.5.3, current host: 192.168.1.103
[DUBBO] Notify urls for subscribe url [dubbo://192.168.1.103:20880/com.cqupt.dubbo.service.HelloDubboService?anyhost=true&application=consumer&dubbo=2.5.3&interface=com.cqupt.dubbo.service.HelloDubboService&methods=helloDubbo&pid=18900&side=provider&timestamp=1524742086150, empty://192.168.1.103/com.cqupt.dubbo.service.HelloDubboService?application=consumer&category=configurators&dubbo=2.5.3&interface=com.cqupt.dubbo.service.HelloDubboService&methods=helloDubbo&pid=18968&side=consumer&timestamp=1524742106566, empty://192.168.1.103/com.cqupt.dubbo.service.HelloDubboService?application=consumer&category=routers&dubbo=2.5.3&interface=com.cqupt.dubbo.service.HelloDubboService&methods=helloDubbo&pid=18968&side=consumer&timestamp=1524742106566], dubbo version: 2.5.3, current host: 192.168.1.103
[DUBBO] Successed connect to server /192.168.1.103:20880 from NettyClient 192.168.1.103 using dubbo version 2.5.3, channel is NettyChannel [channel=[id: 0x013e7344, /192.168.1.103:56955 => /192.168.1.103:20880]], dubbo version: 2.5.3, current host: 192.168.1.103
[DUBBO] Start NettyClient hetiantian/192.168.1.103 connect to the server /192.168.1.103:20880, dubbo version: 2.5.3, current host: 192.168.1.103
[DUBBO] Refer dubbo service com.cqupt.dubbo.service.HelloDubboService from url zookeeper://127.0.0.1:2181/com.alibaba.dubbo.registry.RegistryService?anyhost=true&application=consumer&check=false&dubbo=2.5.3&interface=com.cqupt.dubbo.service.HelloDubboService&methods=helloDubbo&pid=18968&side=consumer&timestamp=1524742106566, dubbo version: 2.5.3, current host: 192.168.1.103

说明dubbo服务启动成功并且已经注册到了zk中

程序运行结果：

运行结果.png

可能会遇到的问题：

• 访问报错

java.lang.IllegalArgumentException: Invalid character found in method name. 
HTTP method names must be tokens

https请求-->http请求

• log4j加载错误

Caused by: java.lang.ClassNotFoundException: org.apache.log4j.Logger
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~[na:1.8.0_161]
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[na:1.8.0_161]
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338) ~[na:1.8.0_161]
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[na:1.8.0_161]
    ... 35 common frames omitted

将启动父依赖的版本从2.0.1.RELEASE-->1.5.1.RELEASE

• 启动报错

java.net.ConnectException: Connection refused: no further information
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_161]
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_161]
    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361) ~[zookeeper-3.4.6.jar:3.4.6-1569965]
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081) ~[zookeeper-3.4.6.jar:3.4.6-1569965]

zookeeper(zk)安装失败。皮皮甜昨天遇到这个问题以为是zookeeper版本和dubbo版本冲突，装了很多不同版本的zk，但是都没有解决。最后发现是zk安装失败了，皮皮甜安装失败的原因是配置文件中data和log的路径没有写正确

• 启动程序不报错，但是dubbo服务没有启动并且没有注册到zk中
  公共api需要在相同的package下，即com.cqupt.dubbo.service

  
  点个喜欢在走吧.png

附:完整项目地址