spring boot 整合Dubbo/Zookeeper

一、技术介绍

•ZooKeeper

ZooKeeper 是一个分布式的，开放源码的分布式应用程序协调服务。它是一个为分布式应用提供一致***的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。

•Dubbo

Dubbo是Alibaba开源的分布式服务框架，它最大的特点是按照分层的方式来架构，使用这种方式可以使各个层之间解耦合（或者最大限度地松耦合）。从服务模型的角度来看，Dubbo采用的是一种非常简单的模型，要么是提供方提供服务，要么是消费方消费服务，所以基于这一点可以抽象出服务提供方（Provider）和服务消费方（Consumer）两个角色。

二、环境

zookeeper的docker启动

docker pull zookeeper

docker run --name zk01 -p 2181:2181 --restart always -d zookeeper

三、搭建两个springboot项目

provider-ticket：服务提供者

1、maven依赖

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.7</version>
</dependency>

<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>2.8.0</version>
</dependency>

<dependency>
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.10</version>
</dependency>

2、服务类接口

public interface TicketService {
   
    String getTicket();
}

3、服务类实现

import com.caleb.ticket.service.TicketService;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.stereotype.Component;

@Component
@DubboService
public class TicketServiceImpl implements TicketService {
   
    @Override
    public String getTicket() {
   
        return "《战狼2》";
    }
}

dubbo之前版本也用的是@Service注解，不要用混了；新版本用的@DubboService

需要加@Component注解

4、application.properties配置

dubbo.application.name=provider-ticket  # dubbo应用名称

dubbo.registry.address=zookeeper://192.168.183.128:2181   # zookeeper集群注册中心地址

dubbo.scan.base-packages=com.caleb.ticket.service # 扫描指定包，将使用@DubboService注解修饰的类发布为服务

5、启动类

import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo
public class ProviderTicketApplication {
   

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

}

consumer-user：服务消费者

1、maven依赖

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.7</version>
</dependency>

<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>2.8.0</version>
</dependency>

<dependency>
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.10</version>
</dependency>

2、服务类接口

1）、直接拷贝provider-ticket项目中的TicketService

2）、UserService类

import com.alibaba.dubbo.config.annotation.Reference;
import com.caleb.ticket.service.TicketService;
import org.springframework.stereotype.Service;


@Service
public class UserService {
   

    @Reference
    TicketService ticketService;

    public void hello() {
   
        String ticket = ticketService.getTicket();
        System.out.println("ticket = " + ticket);
    }
}

4、application.properties配置

dubbo.application.name=consumer-user

dubbo.registry.address=zookeeper://192.168.183.128:2181

5、测试启动类

import com.caleb.user.service.UserService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class ConsumerUserApplicationTests {
   

	@Autowired
	UserService userService;
	@Test
	void contextLoads() {
   
		userService.hello();
	}

}

四、启动测试-----结果

先运行ProviderTicketApplication，在运行ConsumerUserApplicationTests