一、zookeeper 環(huán)境安裝搭建

搭建 zookeeper 之前要確保當(dāng)前的機(jī)器已經(jīng)有 JDK 環(huán)境。

我使用的是 CentOS 7.5 華為云服務(wù)器，

注意：如果你也同樣華為云服務(wù)器必須配置一個(gè)安全組，不然你的應(yīng)用程序會(huì)無(wú)法訪問(wèn)你的 zookeeper 服務(wù)器，這一點(diǎn)我在后面也提到了。

二、實(shí)現(xiàn)服務(wù)接口 dubbo-interface

主要分為下面幾步：

• 創(chuàng)建 Maven 項(xiàng)目;
• 創(chuàng)建接口類
• 將項(xiàng)目打成 jar 包供其他項(xiàng)目使用

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

dubbo-interface 后面被打成 jar 包，它的作用只是提供接口。

1. dubbo-interface 項(xiàng)目創(chuàng)建

??File->New->Module...?? ,然后選擇 Maven類型的項(xiàng)目，其他的按照提示一步一步走就好。

2. 創(chuàng)建接口類

public interface HelloService {
public String sayHello(String name);
}

3. 將項(xiàng)目打成 jar 包供其他項(xiàng)目使用

點(diǎn)擊右邊的 ??Maven Projects?? 然后選擇 install ，這樣 jar 包就打好了。

三、實(shí)現(xiàn)服務(wù)提供者 dubbo-provider

主要分為下面幾步：

• 創(chuàng)建 springboot 項(xiàng)目;
• 加入 dubbo 、zookeeper以及接口的相關(guān)依賴 jar 包；
• 在 application.properties 配置文件中配置 dubbo 相關(guān)信息；
• 實(shí)現(xiàn)接口類;
• 服務(wù)提供者啟動(dòng)類編寫

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

1. dubbo-provider 項(xiàng)目創(chuàng)建

創(chuàng)建一個(gè) SpringBoot 項(xiàng)目，注意勾選上 web 模塊。

2. pom 文件引入相關(guān)依賴

需要引入 dubbo 、zookeeper以及接口的相關(guān)依賴 jar 包。注意將本項(xiàng)目和 ??dubbo-interface?? 項(xiàng)目的 ??dependency?? 依賴的 ??groupId?? 和 ??artifactId?? 改成自己的。

dubbo 整合spring boot 的 jar 包在這里找??dubbo-spring-boot-starter??。zookeeper 的 jar包在 Maven 倉(cāng)庫(kù) 搜索 ??zkclient?? 即可找到。

<dependency>
<groupId>top.snailclimb</groupId>
<artifactId>dubbo-interface</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!--引入dubbo的依賴-->
<dependency>
<groupId>com.alibaba.spring.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.0.0</version>
</dependency>
<!-- 引入zookeeper的依賴 -->
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.10</version>
</dependency>

3. 在 application.properties 配置文件中配置 dubbo 相關(guān)信息

配置很簡(jiǎn)單，這主要得益于 springboot 整合 dubbo 專屬的??@EnableDubboConfiguration?? 注解提供的 Dubbo 自動(dòng)配置。

# 配置端口
server.port=8333
spring.dubbo.application.name=dubbo-provider
spring.dubbo.application.registry=zookeeper://ip地址:2181

4. 實(shí)現(xiàn)接口

注意：??@Service?? 注解使用的時(shí) Dubbo 提供的而不是 Spring 提供的。另外，加了Dubbo 提供的 ??@Service?? 注解之后還需要加入

import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;
import top.snailclimb.service.HelloService;

@Component
@Service
public class HelloServiceImpl implements HelloService {
@Override
public String sayHello(String name){
return "Hello " + name;
}
}

5. 服務(wù)提供者啟動(dòng)類編寫

注意：不要忘記加上 ??@EnableDubboConfiguration?? 注解開啟Dubbo 的自動(dòng)配置。

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
// 開啟dubbo的自動(dòng)配置
@EnableDubboConfiguration
public class DubboProviderApplication {
public static void main(String[] args){
SpringApplication.run(DubboProviderApplication.class, args);
}
}

四、實(shí)現(xiàn)服務(wù)消費(fèi)者 dubbo-consumer

主要分為下面幾步：

• 創(chuàng)建 springboot 項(xiàng)目;
• 加入 dubbo 、zookeeper以及接口的相關(guān)依賴 jar 包；
• 在 application.properties 配置文件中配置 dubbo 相關(guān)信息；
• 編寫測(cè)試類;
• 服務(wù)消費(fèi)者啟動(dòng)類編寫
• 測(cè)試效果

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

第1，2，3 步和服務(wù)提供者的一樣，這里直接從第 4 步開始。

4. 編寫一個(gè)簡(jiǎn)單 Controller 調(diào)用遠(yuǎn)程服務(wù)

import com.alibaba.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import top.snailclimb.service.HelloService;

@RestController
public class HelloController {
@Reference
private HelloService helloService;

@RequestMapping("/hello")
public String hello(){
String hello = helloService.sayHello("world");
System.out.println(helloService.sayHello("CrazyK"));
return hello;
}
}

5. 服務(wù)消費(fèi)者啟動(dòng)類編寫

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubboConfiguration
public class DubboConsumerApplication {

public static void main(String[] args){

SpringApplication.run(DubboConsumerApplication.class, args);
}
}

五、測(cè)試

瀏覽器訪問(wèn) ??http://localhost:8330/hello?? 頁(yè)面返回 ??Hello world??，控制臺(tái)輸出Hello SnailClimb??，和預(yù)期一致，使用SpringBoot+Dubbo 搭建第一個(gè)簡(jiǎn)單的分布式服務(wù)實(shí)驗(yàn)成功！

到此這篇關(guān)于Spring與Dubbo搭建一個(gè)簡(jiǎn)單的分布式詳情的文章就介紹到這了,更多相關(guān)Spring Dubbo搭分布式內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論