前期準(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
服務(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)類
@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è)類申明為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)用名稱
spring.dubbo.registry.address:注冊(cè)地址
spring.dubbo.protocol.name:協(xié)議名稱
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)類
@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 服務(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寫到獨(dú)立的項(xiàng)目中，并生成一個(gè)依賴氯迂。另外一種是每個(gè)項(xiàng)目中都寫這個(gè)公共api践叠，其中服務(wù)提供者需要實(shí)現(xiàn)公共api，而服務(wù)調(diào)用者只需寫公共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×tamp=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×tamp=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×tamp=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×tamp=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×tamp=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×tamp=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)]有寫正確
-
啟動(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
