SpringBoot整合Dubbo

前期準(zhǔn)備:下載安裝zookeeper作為服務(wù)注冊(cè)中心

安裝步驟

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

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

  • 啟動(dòng)zookeeper
cd zookeeper-3.3.6
cd bin
./zkServer.sh start

附：zookeeper下載地址

服務(wù)提供者

  • 項(xiàng)目結(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的實(shí)現(xiàn)類(lèi)
@Service
public class HelloDubboServiceImpl implements HelloDubboService {
    @Override
    public String helloDubbo() {
        return "hello dubbo";
    }
}

@Service注解導(dǎo)入的包為com.alibaba.dubbo.config.annotation.Service;，通過(guò)這個(gè)注解將這個(gè)類(lèi)申明為dubbo服務(wù)

  • 配置文件:application.properties
server.port=8080

## Dubbo 服務(wù)消費(fèi)者配置
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:應(yīng)用名稱(chēng)
spring.dubbo.registry.address:注冊(cè)地址
spring.dubbo.protocol.name:協(xié)議名稱(chēng)
spring.dubbo.protocol.port:協(xié)議端口
spring.dubbo.scan:掃描的包
只有服務(wù)提供者配置文件中需要配置spring.dubbo.protocol.name和spring.dubbo.protocol.port，服務(wù)消費(fèi)者不需要

服務(wù)調(diào)用者

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


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

  • 依賴
    和服務(wù)提供者差不多

  • 公共api的實(shí)現(xiàn)類(lèi)

@Service
public class HelloDubboServiceImpl implements HelloDubboService {
    @Override
    public String helloDubbo() {
        return "hello dubbo";
    }
}
  • 控制類(lèi):HelloDubboController .java
@RestController
public class HelloDubboController {
    @Reference
    private HelloDubboService helloDubboService;

    @RequestMapping("/hello")
    public String helloDubbo() {
        return helloDubboService.helloDubbo();
    }
}
  • 配置文件:application.properties
server.port=8081

## Dubbo 服務(wù)消費(fèi)者配置
spring.dubbo.application.name=consumer
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
spring.dubbo.scan=com.cqupt.dubbo.service

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

啟動(dòng)

1.啟動(dòng)zookeeper
2.啟動(dòng)SpringBoot-Dubbo-Provider
3.啟動(dòng)SpringBoot-Dubbo-Consumer
啟動(dòng)服務(wù)提供者和服務(wù)調(diào)用者時(shí)，只有都出現(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

說(shuō)明dubbo服務(wù)啟動(dòng)成功并且已經(jīng)注冊(cè)到了zk中

程序運(yùn)行結(jié)果：
運(yùn)行結(jié)果.png
可能會(huì)遇到的問(wèn)題：
  • 訪問(wèn)報(bào)錯(cuò)
java.lang.IllegalArgumentException: Invalid character found in method name. 
HTTP method names must be tokens

https請(qǐng)求-->http請(qǐng)求

  • log4j加載錯(cuò)誤
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

將啟動(dòng)父依賴的版本從2.0.1.RELEASE-->1.5.1.RELEASE

  • 啟動(dòng)報(bào)錯(cuò)
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)安裝失敗。皮皮甜昨天遇到這個(gè)問(wèn)題以為是zookeeper版本和dubbo版本沖突，裝了很多不同版本的zk，但是都沒(méi)有解決。最后發(fā)現(xiàn)是zk安裝失敗了，皮皮甜安裝失敗的原因是配置文件中data和log的路徑?jīng)]有寫(xiě)正確

  • 啟動(dòng)程序不報(bào)錯(cuò)，但是dubbo服務(wù)沒(méi)有啟動(dòng)并且沒(méi)有注冊(cè)到zk中
    公共api需要在相同的package下，即com.cqupt.dubbo.service


    點(diǎn)個(gè)喜歡在走吧.png

附:完整項(xiàng)目地址

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

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

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

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