Spring Boot + Dubbo 可运行的例子源码-实现服务注册和远程调用

最近公司的一个分布式系统想要尝试迁移到Dubbo，项目本身是Spring Boot的，经过一些努力，最终也算是搭建起一个基础的框架了，放到这里记录一下。需要依赖一个外部的zookeeper。

源码地址：点我

项目结构：



Maven构建的Spring Boot 多模块项目，provide为服务提供者，开放出接口供外部访问；consume为服务消费者，RPC调用provide提供的服务。

Provide

Dubbo配置类：

@Configuration
@PropertySource("classpath:dubbo/dubbo.properties")
@ImportResource({ "classpath:dubbo/*.xml" })
public class DubboConfig {

}

在resources下新建dubbo文件，并添加 dubbo-provider.xml文件：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> 
<dubbo:application name="${dubbo.application.name}"/>

<dubbo:registry protocol="${dubbo.registry.protocol}" address="${dubbo.registry.address}"/>

<dubbo:protocol name="${dubbo.protocol.name}" port="${dubbo.protocol.port}"/>

<dubbo:service interface="com.csonezp.TestService"
ref="testService" retries="0" timeout="6000"/>
</beans>

dubbo.properties文件：

#应用名称
dubbo.application.name=example-provider
#注册中心类型
dubbo.registry.protocol=zookeeper
#注册中心地址
dubbo.registry.address=127.0.0.1:2181
#暴露服务方式
dubbo.protocol.name=dubbo
#暴露服务端口
dubbo.protocol.port=20880

com.csonezp.TestService：

public interface TestService {
String test();
}

TestServiceImpl：

@Service("testService")
public class TestServiceImpl implements TestService {
@Override
public String test() {
return "message from provide";
}
}

xml文件中的 ref="testService" 很重要，后面consume需要通过这个来进行RPC访问。

Consume

Dubbo配置类：

/**
* Created by csonezp on 2017/9/14.
*/
@Configuration
@PropertySource("classpath:dubbo/dubbo.properties")
@ImportResource({ "classpath:dubbo/*.xml" })
public class DubboConfig {
}

在resources下新建dubbo目录，添加dubbo-consume.xml文件：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> 
<dubbo:application name="${dubbo.application.name}"/>

<dubbo:registry protocol="${dubbo.registry.protocol}" address="${dubbo.registry.address}"/>

<dubbo:reference id="testService" interface="com.csonezp.TestService"/>
</beans>

这个id 就是Provide里设置的ref，不要错了；

dubbo.properties文件：

#应用名称
dubbo.application.name=example-consume
#注册中心类型
dubbo.registry.protocol=zookeeper
#注册中心地址
dubbo.registry.address=127.0.0.1:2181

TestService：

/**
* Created by csonezp on 2017/9/14.
*/
public interface TestService {
String test();
}

仅需要一个接口，不需要实现，通过远程调用来调用Provide的具体实现；

TestController：具体测试入口，调用远程Provide的实现：

@RestController
public class TestController {

@Autowired
TestService testService;
@RequestMapping("/test")
public Object test() {
return testService.test();
}
}

还需要修改一下consume的端口，防止冲突，在consume的application.properties加入：

server.port=8081

现在将Provide和Consume都启动，然后访问 localhost:8081/test，这时会得到：



可知项目已经正确的执行了远程调用。