剛做完一個(gè)基于motan的項(xiàng)目不久，便去看看dubbo的新特性了，dubbo自上年9月恢復(fù)更新到現(xiàn)在大概半年多，發(fā)現(xiàn)已經(jīng)有和spring boot集成的配置了。個(gè)人喜歡的配置方式優(yōu)先級(jí)一般都是資源文件>Bean>xml，因感覺(jué)而言Bean的配置方式更適合讓人了解源碼，而資源文件則是最簡(jiǎn)便，看了下還好之前寫dubbo的demo時(shí)沒(méi)有寫文章，因?yàn)槲乙话愣急容^喜歡寫可以通過(guò)最簡(jiǎn)易的方式達(dá)到目的的demo文章，而且也不會(huì)也重復(fù)的文章，如果之前寫了就只有通過(guò)Bean配置而沒(méi)有application資源文件配置dubbo的文章了。
???????該文章主要參考自 dubbo官方Demo，dubbo的基本特性可以看用戶指南，dubbo的概念可以看用戶指南的第一章入門即可，我就不轉(zhuǎn)述了，想要在dubbo基礎(chǔ)上擴(kuò)展的可以看開(kāi)發(fā)指南。建議可以先嘗試自己根據(jù)官方去搭一下，出問(wèn)題了可以再對(duì)比一下本文章代碼找出問(wèn)題，成功了就可以省略代碼部分閱覽了。
現(xiàn)在可以通過(guò)添加dubbo-spring-boot-starter依賴實(shí)現(xiàn)dubbo與spring boot的整合，簡(jiǎn)化dubbo的配置，具體文檔如下圖:
文檔所屬項(xiàng)目是dubbo-spring-boot-parent,由于0.2.x版本還沒(méi)正式release,所以該demo用的依舊是0.1.0的依賴，但還未發(fā)現(xiàn)與Spring boot 2.0的版本繼承有問(wèn)題。
個(gè)人demo分了3個(gè)模塊-consumer、provider、service，這3個(gè)模塊的父模塊則是dubbo-demo。service里存放服務(wù)接口和POJO(按正常劃分POJO該新建一個(gè)entity模塊存放，但demo隨便了一下)，provider存放DAO、service接口實(shí)現(xiàn)暴露service，consumer存放controller(controller從暴露服務(wù)的位置獲取所需服務(wù)，如consule、zookeeper為分布式服務(wù)進(jìn)行管理的注冊(cè)中心，也可以是特定url)。dubbo-motan的maven依賴如下：
dubbo-service-demo模塊存服務(wù)接口與POJO:
package per.dubbo.demo.postgres.service;
import per.dubbo.demo.postgres.model.Student;
import com.baomidou.mybatisplus.service.IService;
/**
* @author Wilson
* @since 2018-05-25
*/
public interface StudentService extends IService {
}
dubbo-provider-demo存放服務(wù)、DAO與dubbo配置資源文件properties.yml(@Service需用dubbo的)：
StudentServiceImpl:
package per.dubbo.demo.postgres.service.impl;
import com.alibaba.dubbo.config.annotation.Service;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import per.dubbo.demo.postgres.dao.StudentDAO;
import per.dubbo.demo.postgres.model.Student;
import per.dubbo.demo.postgres.service.StudentService;
import javax.annotation.Resource;
/**
* @author Wilson
* @since 2018-05-25
*/
@Service
public class StudentServiceImpl extends ServiceImpl implements StudentService {
@Resource
private StudentDAO studentDAO;
}
dubbo-provider-demo模塊下的application.xml：?
server:
port: 8081
spring:
application:
name: provider-demo
dubbo:
scan:
base-packages: per.dubbo.demo.postgres.service.impl
application:
name: dubbo-provider-demo
id: dubbo-provider-demo
protocol:
id: dubbo
name: dubbo
port: 33333
registry:
address: multicast://224.5.6.7:1234
check: false
啟動(dòng)進(jìn)程ProviderApplicationDemo（@EnableDubbo同@DubboComponentScan與@EnableDubboConfig,雖然application.yml已配置了掃描包但實(shí)際啟動(dòng)卻沒(méi)有起效，大概是我使用的spring boot版本是2.0但dubbo-spring-boot是0.1.x的原因，所以要加@EnableDubbo才能起效）:
package per.dubbo.demo.postgres;
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import io.swagger.annotations.Api;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* ProviderApplicationDemo
*
* @author Wilson
* @date 18-4-12
*/
@Api("ProviderApplicationDemo")
@EnableDubbo
@SpringBootApplication
public class ProviderApplicationDemo {
public static void main(String[] args) {
SpringApplication.run(ProviderApplicationDemo.class);
}
}
dubbo-consumer-demo存放controller：
package per.dubbo.demo.controller.impl;
import com.alibaba.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RestController;
import per.dubbo.demo.common.ServerResponse;
import per.dubbo.demo.controller.UserBaseController;
import per.dubbo.demo.postgres.service.StudentService;
import reactor.core.publisher.Mono;
/**
* UserBaseControllerImpl
*
* @author Wilson
* @date 18-5-25
*/
@RestController
public class UserBaseControllerImpl implements UserBaseController {
@Reference
private StudentService studentService;
@Override
public Mono login(String username, String password) {
return Mono.just(ServerResponse.ok());
}
@Override
public Mono list() {
return Mono.just(ServerResponse.ok(studentService.selectList(null)));
}
}
啟動(dòng)程序ConsumerDemoApplication（@PostConstruct在這只是用來(lái)判斷有沒(méi)有成功發(fā)現(xiàn)服務(wù)）:?
package per.dubbo.demo;
import com.alibaba.dubbo.config.annotation.Reference;
import com.alibaba.dubbo.config.spring.context.annotation.DubboComponentScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import per.dubbo.demo.postgres.service.StudentService;
import javax.annotation.PostConstruct;
/**
* ConsumerDemoApplication
*
* @author Wilson
* @date 18-5-15
*/
@SpringBootApplication
@DubboComponentScan
public class ConsumerDemoApplication {
@Reference
private StudentService studentService;
@PostConstruct
public void init() {
System.err.println("studentService:" + studentService);
}
public static void main(String[] args) {
SpringApplication.run(ConsumerDemoApplication.class);
}
}
consumer配置文件application.yml:
spring:
application:
name: dubbo-consumer-demo
server:
port: 7979
dubbo:
consumer:
check: false
application:
id: dubbo-consumer
name: dubbo-consumer
protocol:
id: consumer
name: consumer
port: 33333
registry:
address: multicast://224.5.6.7:1234
check: false
scan:
base-packages: per.dubbo.demo.controller
項(xiàng)目起跑時(shí)都可以看到控制臺(tái)輸出application.yml的dubbo配置信息，如下圖:
這一切都部署好后就把每一個(gè)Consumer模塊都當(dāng)作一個(gè)系統(tǒng)開(kāi)發(fā)就好了，其它無(wú)關(guān)dubbo配置的代碼就不貼浪費(fèi)位置了，畢竟最重要的還是思想。分布式就相當(dāng)于把一個(gè)大系統(tǒng)劃分為一個(gè)個(gè)小系統(tǒng)進(jìn)行開(kāi)發(fā)，而dubbo就是劃分的代碼實(shí)現(xiàn)。如電商就可分為用戶Consumer、用戶Provider、商品Consumer、商品Provider、訂單Consumer、訂單Provider等等，不同的consumer可以放到一個(gè)consumer大模塊進(jìn)行管理，provider丟到一個(gè)provider大模塊進(jìn)行管理，按照該文章里的例子則dubbo-demo則為所有模塊的祖宗，根據(jù)功能劃分存放common、provider-demo、consumer-demo、service-demo、entity等子模塊，consumer-demo里放user-consumer、order-consumer、store-consumer等子模塊，provider-demo放user-provider、order-provider、store-provider等子模塊
