Spring Boot集成dubbo快速入门Demo

1.什么是dubbo？

Apache Dubbo 是一款微服务开发框架，它提供了 RPC通信与微服务治理两大关键能力。这意味着，使用 Dubbo 开发的微服务，将具备相互之间的远程发现与通信能力，同时利用 Dubbo 提供的丰富服务治理能力，可以实现诸如服务发现、负载均衡、流量调度等服务治理诉求。同时 Dubbo 是高度可扩展的，用户几乎可以在任意功能点去定制自己的实现，以改变框架的默认行为来满足自己的业务需求。

2.zookeeper环境搭建

Dubbo使用zookeeper作为注册中心，所以需要安装zookeeper。

version: '3'
services:zookeeper:image: zookeeper:3.7.0container_name: zookeeperrestart: unless-stoppedvolumes:- "./zookeeper/data:/data"- "./zookeeper/datalog:/datalog"ports:- "2181:2181"# webuizookeeper-webui:image: tobilg/zookeeper-webuicontainer_name: zookeeper-webuirestart: unless-stoppedenvironment:ZK_DEFAULT_NODE: zookeeper:2181depends_on:- zookeeperlinks:- zookeeperports:- "8089:8080"

启动

docker-compose -f docker-compose-zookeeper.yml -p zookeeper up -d

可视化界面访问地址：[http://ip地址:8089] ,输入 [{宿主主机ip}:2181/]进入桌面可视化工具PrettyZoo: GitHub - vran-dev/PrettyZoo: 😉 Pretty nice Zookeeper GUI, Support Win / Mac / Linux Platform

3.代码工程

实验目的：实现dubbo远程调用

dubbo-samples-spring-boot-interface

api层，暴露给consumer和provider引用

<!--api  -->
<dependency><groupId>com.et</groupId><artifactId>dubbo-samples-spring-boot-interface</artifactId><version>1.0-SNAPSHOT</version>
</dependency>

package com.et.api.entity;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;import java.io.Serializable;@Data
@NoArgsConstructor
@AllArgsConstructor
public class User implements Serializable {private static final long serialVersionUID = -4294369157631461921L;Long userId;String userName;String userInfo;
}

package com.et.api;import com.et.api.entity.User;public interface UserService {String getUserInfo();User getUserById(String userId);
}

dubbo-samples-spring-boot-provider

服务提供层，把服务注册到zookeeper上

package com.et.provider.service;import com.et.api.UserService;
import com.et.api.entity.User;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;/*** 注意，@service注解，引入的包是org.apache.dubbo.config.annotation.Service*/
@Service
@Component
@Slf4j
public class UserServiceImpl implements UserService {@Overridepublic String getUserInfo() {log.info("this is a test");return "userTest";}@Overridepublic User getUserById(String userId) {log.info("invoke getUserById method");User user = new User();user.setUserId(Long.valueOf(userId));user.setUserInfo("test");user.setUserName("lin");return user;}}

package com.et.provider;import org.apache.dubbo.config.spring.context.annotation.DubboComponentScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;/*** DubboComponentScan service package*/
@SpringBootApplication
@DubboComponentScan("com.et.provider.service")
public class DubboProviderApplication {public static void main(String[] args) {SpringApplication.run(DubboProviderApplication.class, args);}}

dubbo:application:# 应用名称name: dubbo-providerprotocol:# 协议名称name: dubbo# 协议端口port: 20880registry:# 注册中心地址address: zookeeper://127.0.0.1:2181server:# 修改端口号，避免端口冲突port: 8081

dubbo-samples-spring-boot-consumer

消费应用，调用provider服务

package com.et.consumer.controller;import com.et.api.UserService;
import com.et.api.entity.User;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping("/user")
public class ConsumerController {/***  @Reference invoker dubbo-provider*/@Referenceprivate UserService userService;@GetMapping("/info")public String getUserById() {return userService.getUserInfo();}@GetMapping("/{id}")public User getUserById(@PathVariable String id) {return userService.getUserById(id);}}

以上只是一些关键代码，所有代码请参见下面代码仓库