springboot与dubbo的集成是非常简单的。
dubbo是专门为分布式开发而创建的。其核心有四个：服务提供者、服务消费者、服务的注册与发现和服务的监控。
dubbo的远程调用和异步通信的底层是hession，所以项目的实体类都要实现序列化。本案例是将服务注册保存到zookeeper中。
dubbo-admin
dubbo监控管理界面
先创建两个springboot项目，命名为dubboprovider和dubboconsumer。parentversion选择1.5.1以上即可，两个都需要导入dubbo的依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>io.dubbo.springboot</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>1.0.0</version>
</dependency>
配置服务提供者的*.properties文件
#8080端口被dubbo-admin给占用过了，重新指定
server.port=9004
#服务名称
spring.dubbo.application.name=my_provider
#指定注册中心的地址
spring.dubbo.registry.address=zookeeper://localhost:2181
#指定dubbo端口
spring.dubbo.protocol.port=20880
#指定协议为dubbo协议
spring.dubbo.protocol.name=dubbo
#发布服务的类包路径
spring.dubbo.scan=com.uap.testdubboservice
服务提供者创建服务接口。
public interface TestDubbo {
public String getname(String name);
}
服务提供者创建实现类。
@Service(version = "1.0.0") //注意此service是阿里的包里面的，不然服务发布不成功
public class TestDubboimpl implements TestDubbo {
/* (non-Javadoc)
* @see com.uap.testdubboservice.TestDubbo#getname(java.lang.String)
*/
@Override
public String getname(String name) {
// TODO Auto-generated method stub
return name;
}
}
服务提供者代码到此就结束啦，启动即可。
注意：若是代码没有问题，启动时候却报错为空指针的情况（我遇到了，一开始使用注解时候什么错误也不报，直接启动完成，可是服务却没有注册上，于是我就换做xml配置文件方式，当然xml配置是比注解方式稍显麻烦啦。在xml配置方式的情况下，启动会报出找不到接口TestDubbo，我是加@Service呀还是加@Component呀还是在xml文件内加入componet-scan扫描都不行，可把我气坏了，愣是弄了快一天！！），多半是包的结构有问题。服务接口和实现类的包路径关系是接口必须在实现类的上方，接口和实现类在同一包下也是可以的，当然，我们不会这做、、、
服务发布
点击address可以查看具体的服务详情（服务名称、服务方法、版本、状态等等）
配置服务消费者的*.properties文件
#端口号
server.port=9001
spring.dubbo.application.name=consumer-1
#zk地址
spring.dubbo.registry.address=zookeeper://localhost:2181
#dubbo协议
spring.dubbo.protocol.name=dubbo
#这是要扫描使用的dubbo接口所在包位置
spring.dubbo.scan=com.uap.testdubboservice
我们需要将服务提供接口拷贝到消费者里，包的路径也不能改变，最好整个接口包一起拷进来
编写消费者的controller层
@RestController
public class DubboController {
//不能用@Autowired引入服务接口,里面的版本号也必须要和服务提供者@service里的version对应不然会找不到服务提供者
@Reference(version = "1.0.0")
private TestDubbo dubbo1;
@RequestMapping("/getname")
public String getname(@PathParam("name") String name){
System.out.println(name);
return dubbo1.getname(name);
}
}
消费者.PNG
点进address即可查看消费者详情。
后面的notified(1)也可以点进去看一看，当有多个服务提供者dubbo应该就会自动采取负载均衡来平衡各个服务提供者的压力。
