SpringBoot整合Dubbo

前期準備:下載安裝zookeeper作為服務注冊中心

安裝步驟

  • 解壓
tar zxvf zookeeper-3.4.8.tar.gz
  • 將zoo_sample.cfg文件名修改為zoo.cfg，并修改配置文件中的內(nèi)容。
    默認為zoo.cfg，可以查看zookeeper-3.4.6\bin\zkEnv.cmd
dataDir=C:\\Users\\tianthe\\zk\\data
dataLogDir=C:\\Users\\tianthe\\zk\\log

修改數(shù)據(jù)存放的文件目錄，并添加了存放日志文件的文件目錄

  • 啟動zookeeper
cd zookeeper-3.3.6
cd bin
./zkServer.sh start

附：zookeeper下載地址

服務提供者

  • 項目結(jié)構(gòu)


    provider結(jié)構(gòu)圖.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的實現(xiàn)類
@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
## 數(shù)據(jù)源配置
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:協(xié)議名稱
spring.dubbo.protocol.port:協(xié)議端口
spring.dubbo.scan:掃描的包
只有服務提供者配置文件中需要配置spring.dubbo.protocol.name和spring.dubbo.protocol.port，服務消費者不需要

服務調(diào)用者

  • 項目結(jié)構(gòu)


    Consumer結(jié)構(gòu)圖.png

  • 依賴
    和服務提供者差不多

  • 公共api的實現(xiàn)類

@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

服務提供者和服務調(diào)用者公用一份api，一種是將公共api寫到獨立的項目中，并生成一個依賴。另外一種是每個項目中都寫這個公共api，其中服務提供者需要實現(xiàn)公共api，而服務調(diào)用者只需寫公共api即可
該項目的公共api為:helloDubboService

啟動

1.啟動zookeeper
2.啟動SpringBoot-Dubbo-Provider
3.啟動SpringBoot-Dubbo-Consumer
啟動服務提供者和服務調(diào)用者時，只有都出現(xiàn)：

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服務啟動成功并且已經(jīng)注冊到了zk中

程序運行結(jié)果：
運行結(jié)果.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，但是都沒有解決。最后發(fā)現(xiàn)是zk安裝失敗了，皮皮甜安裝失敗的原因是配置文件中data和log的路徑?jīng)]有寫正確

  • 啟動程序不報錯，但是dubbo服務沒有啟動并且沒有注冊到zk中
    公共api需要在相同的package下，即com.cqupt.dubbo.service


    點個喜歡在走吧.png

附:完整項目地址

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務。

相關閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具（例如配置管理，服務發(fā)現(xiàn)，斷路器，智...
    卡卡羅2017閱讀 136,616評論 19贊 139
  • 最近聽聞公司的項目打算進行重構(gòu)，大佬們商量準備使用近年大火的SpringCloud，所以在開始學習Springcl...
    Ranger23閱讀 38,023評論 4贊 14
  • 看著順從的不再反抗的小小背影被老師抱進幼兒園的一幕，心里難免有些落寞，孩子已經(jīng)適應這種她不太愿意接受的生活，...
    點點星625閱讀 179評論 0贊 3
  • 01417歐陽微 如果讓孩子養(yǎng)成每天早晚刷牙，飯后漱口的習慣，是很多寶媽寶爸感到困繞的事?！堆例X大街的新鮮事...
    微微姐姐閱讀 581評論 0贊 0

友情鏈接更多精彩內(nèi)容