springboot集成dubbo

springboot与dubbo的集成是非常简单的。
dubbo是专门为分布式开发而创建的。其核心有四个：服务提供者、服务消费者、服务的注册与发现和服务的监控。
dubbo的远程调用和异步通信的底层是hession，所以项目的实体类都要实现序列化。本案例是将服务注册保存到zookeeper中。

想要启动dubbo的监控，需要在github上下载dubbo的源码包，解压后找到dubbo-admin，进入到此目录cmd ，然后执行mvn install来将其打包。成功后有一个war包，将这个war包放入到一个tomcat的webapps目录下，然后进入tomcat的bin目录下，启动tomcat后这个war会自动被解压，访问即可见到dubbo的监控界面。 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);
        
    }

}

写的代码很简单，如果启动的时候发现监控中心发现不了消费者那有可能还是因为包的结构有问题，要满足controller层在接口的下一层才能将消费者注册进来。 消费者.PNG

点进address即可查看消费者详情。
后面的notified(1)也可以点进去看一看，当有多个服务提供者dubbo应该就会自动采取负载均衡来平衡各个服务提供者的压力。