分布式Dubbo+ZooKeeper+SpringBoot

分布式Dubbo+ZooKeeper+SpringBoot测试

一、新建一个空项目以及提供者模块

1、新建空项目

2、创建一个提供者模块叫privoder-server

3、引入依赖

<!--导入dubbo+zookeeper的依赖-->
        <!-- https://mvnrepository.com/artifact/org.apache.dubbo/dubbo-spring-boot-starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <!--引入zookeeper，并解决日志冲突问题-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</version>
            <!--排除这个slf4j-log4j12-->
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

4、创建一个service包和一些服务，这里直接贴代码

（1）TicketService

package cn.nongyanxia.service;

public interface TicketService {
    public String getTicket();
}

（2）TicketServiceImpl

package cn.nongyanxia.service;

import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;


@Service //这个是dubbo的注解,一定要注意和spring的注解区分
@Component 
public class TicketServiceImpl implements TicketService {
    @Override
    public String getTicket() {
        return "浓烟下与荒野";
    }
}

（3）配置文件

server.port=8001

# 服务应用名字
dubbo.application.name=privoder-server
# 注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
# 哪些服务要被注册，会扫描此包下添加了@Service注解的类
dubbo.scan.base-packages=cn.nongyanxia.service

二、测试一下上面的服务有没有注册到注册中心

1、一定要保证ZooKeeper是开启的，具体操作看我上一篇博客

2、使用dubbo-admin，接着启动刚刚的提供者模块项目，然后可以看到我们的服务已经注册进去了

三、新建一个消费者模块叫consumer-server

1、同样的引入依赖

<!--导入dubbo+zookeeper的依赖-->
        <!-- https://mvnrepository.com/artifact/org.apache.dubbo/dubbo-spring-boot-starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <!--引入zookeeper，并解决日志冲突问题-->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.12.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</version>
            <!--排除这个slf4j-log4j12-->
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

2、修改配置文件

和提供者不同的是，不需要扫描包

server.port=8002

# 消费者去哪里拿到服务，需要暴露自己的名字
dubbo.application.name=consumer-server

# 注册中心的地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

3、新建一个UserService类来使用另一个模块提供的服务

package cn.nongyanxia.service;


import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

@Service   //这个是spring的注解,交给spring托管
public class UserService {

    //想拿到privoder-server提供的票,要去注册中心拿到服务
    //原来本地是直接@Autowired，现在是@Reference 也一定要是dubbo下面的注解
    @Reference //引用，   1、pom坐标  2、可以定义路径相同的接口名
    TicketService ticketService;


    public void buyTicket(){
        String ticket = ticketService.getTicket();
        System.out.println("在注册中心拿到的票=>"+ticket);
    }
}

4、上一步引用服务我们用的是第二步，所以要建一个和另一个模块路径和内容一模一样的接口

package cn.nongyanxia.service;

public interface TicketService {
    public String getTicket();
}

5、测试可不可以使用另一个模块的服务

测试类：

package cn.nongyanxia;

import cn.nongyanxia.service.UserService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class ConsumerServerApplicationTests {

    @Autowired
    UserService userService;

    @Test
    void contextLoads() {
        userService.buyTicket();//直接调用接口的方法
    }

}

接着运行测试类：