Spring Boot & Dubbo

在spring boot中整合Dubbo，Dubbo的整合在Spring 中和spring boot中有些不一样

创建两个新项目，都是Spring boot项目，其中Consumer的项目中是一个web项目，加入spring boot的web支持

添加依赖

Dubbo 已经给我们写好了Spring Boot的Starter

<dependency>
    <groupId>com.alibaba.boot</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>0.2.0</version>
</dependency>

里面已经内置了dubbo等模块

我们就不用自己手动添加zookeeper和dubbo了

公共api

在项目中新建API模块，取名service-api，这是一个maven项目，里面存放的内容有

Bean
Service的接口
...等公共的部分

Dubbo的入门一样，这里就不多赘述了

服务提供者部分

编写com.dubboLearn.service.impl下的UserServiceImpl

这里的编写基本和入门时一样

public class UserServiceImpl implements UserService {

    public static Map<String,User> userMap;
    static {
        userMap = new HashMap<String, User>();
        userMap.put("1",new User("1","lucas"));
    }
    public User findUserById(String id) {
        return UserServiceImpl.userMap.get(id);
    }

}

配置yaml

众所周知，xml中能够进行配置的yaml中也能进行配置

dubbo:
  application:
    name: provider
  registry:
    protocol: zookeeper
    address: 127.0.0.1:2181
  protocol:
    name: dubbo
    port: 20880
  monitor:
    protocol: registry

我们还差配置暴露哪个服务让别人引用

在UserServiceImpl 上使用注解

@Service
@Component
public class UserServiceImpl implements UserService {

    public static Map<String,User> userMap;
    static {
        userMap = new HashMap<String, User>();
        userMap.put("1",new User("1","lucas"));
    }
    public User findUserById(String id) {
        return UserServiceImpl.userMap.get(id);
    }

}

注意这里的Service

必须是，不要和Spring 的Service搞混
com.alibaba.dubbo.config.annotation.Service

最后在主程序上使用注解

@EnableDubbo
@SpringBootApplication
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }

}

这样服务就进行了注册

消费者部分

和刚刚一样，创建一个Spring boot项目，添加web支持，导入依赖

编写OrderService，这里的@Service注解是Spring的

@Service
public class OrderServiceImpl implements OrderService {

    @Reference
    private UserService userService;

    public UserService getUserService() {
        return userService;
    }

    
    public void setUserService(UserService userService) {
        this.userService = userService;
    }

    public void addOrder() {
        User user = userService.findUserById("1");
        if (user!=null)
            System.out.println(user.getUserName()+"订购了一些东西");
    }
}

配置yaml

server:
  port: 8083
dubbo:
  application:
    name: consumer
  registry:
    protocol: zookeeper
    address: 127.0.0.1:2181
  monitor:
    protocol: registry

里面配置的要远程调用的接口在Serivce中配置

@Reference

编写Controller

@RestController
public class ConsumerController {

    @Reference
    UserService userService;

    @Autowired
    OrderService orderService;

    @RequestMapping("/consume")
    public String consume()
    {
        orderService.addOrder();
        return null;
    }
}

我们先进行注入的第一次实验，如果控制台打印了正确的信息，那么说明远程调用成功

在启动之前别忘了给启动类加上@EnableDubbo

启动后控制台打印出了东西

此时再看到Dubbo Admin

也会显示一些信息

这时我们再更改Controller层的代码

@RequestMapping("/consume")
public String consume()
{
    User user = userService.findUserById("1");
    return user.getUserName()+"订购了一些东西";
}

重新启动服务器，再次访问

如果浏览器显示了对应的文字，那么访问就成功了

dubbo monitor

如果我们多次请求刚刚的页面，多次进行远程调用

并且稍微等一会，monitor中会出现分析图表

大概是这样的，可以看出monitor的作用