Spring Boot 入门（十四）使用dubbo(用redis作为注册中心)

结尾附源码

redis安装教程参考：Spring Boot 入门（三）部署Redis服务

新建一个maven项目，划分三层

common-公共：存放服务声明

comsuer-客户端：存放服务调用

server-服务端：存放服务实现

maven引用

<!-- dubbo 依赖-->
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.8</version>
</dependency>
<!-- dubbo redis 依赖-->
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-registry-redis</artifactId>
    <version>2.7.8</version>
</dependency>
<!-- redis 支持包 -->
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.9.1</version>
</dependency>

common

/**
 * 服务声明
 */
public interface ITicketService {
    String getTicket();
}

server

创建服务实现

import com.example.demo.dubbo.common.ITicketService;
import org.apache.dubbo.config.annotation.DubboService;

import java.util.UUID;

@DubboService(version = "${dubbo.application.version}",
        application = "${dubbo.application.id}",
        protocol = "${dubbo.protocol.id}",
        registry = "${dubbo.registry.id}") //将服务发布出去，注意是dubbo的注解
/**
 * 服务实现
 */
public class TicketServiceImpl implements ITicketService {
    @Override
    public String getTicket() {
        return UUID.randomUUID().toString();
    }
}

创建服务端的启动类

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * 服务启动类
 */
@SpringBootApplication
public class DubboServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(DubboServiceApplication.class, args);
    }
}

服务端配置

# dubbo 服务端配置
dubbo..application.name=server
dubbo.application.id=server
dubbo.application.version=1.0.0
dubbo.protocol.id=dubbo
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
dubbo.registry.id=dubbo-resis
dubbo.registry.address=redis://192.168.233.128:6379
dubbo.registry.username=root
dubbo.registry.password=123456
# 服务扫描位置
dubbo.scan.base-packages=com.example.demo.dubbo

redis没有密码可以删除这两个配置（dubbo.registry.username、dubbo.registry.password）

我的redis有密码，所以需要设置密码，并且dubbo.registry.username随便填。

 

启动DubboServiceApplication

用RDM查询到服务注册成功

comsuer

创建服务调用

import com.example.demo.dubbo.common.ITicketService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.stereotype.Component;

/**
 * 服务调用
 */
@Component
public class UserService {
    @DubboReference(version = "${dubbo.application.version}",
            application = "${dubbo.application.id}",
            registry = "${dubbo.registry.address}") //远程引用指定的服务，他会按照全类名进行匹配，看谁给注册中心注册了这个全类名
    ITicketService ticketService;

    public String bugTicket() {
        String ticket = ticketService.getTicket();
        return "在注册中心拿到:" + ticket;
    }
}

创建客户端的启动类

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * 服务启动类
 */
@SpringBootApplication
public class DubboComsuerApplication {
    public static void main(String[] args) {
        SpringApplication.run(DubboComsuerApplication.class, args);
    }
}

客户端配置

# dubbo 客户端配置
dubbo..application.name=comsuer
dubbo.application.id=comsuer
dubbo.application.version=1.0.0
dubbo.protocol.id=dubbo
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
dubbo.registry.id=dubbo-resis
dubbo.registry.address=redis://192.168.233.128:6379
dubbo.registry.username=root
dubbo.registry.password=123456

测试客户端远程调用服务

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes = DubboComsuerApplication.class)
public class UserServiceTest {
    @Autowired
    UserService userService;

    @Test
    public void bugTicket() {
        System.err.println(userService.bugTicket());
    }

    /**
     * 注入配置文件
     */
    @Configuration
    @PropertySource("classpath:application.properties")
    static class PropertiesWithJavaConfig {

        @Bean
        public static PropertySourcesPlaceholderConfigurer
        propertySourcesPlaceholderConfigurer() {
            return new PropertySourcesPlaceholderConfigurer();
        }
    }
}

测试成功，拿到一串UUID

 源码下载地址：https://download.csdn.net/download/yfq961651795/74416295