doubbo+zookeeper服务注册发现
  TEZNKK3IfmPf 2023年11月13日 19 0
  1. IDEA创建一个空项目;

  2. 创建一个模块,实现服务提供者:provider-server , 选择web依赖即可

Pom依赖:

  <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>
        <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>
#当前应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#扫描指定包下服务
dubbo.scan.base-packages=com.example.service.impl

编写服务:TicketServiceImpl.java

@Service //将服务发布出去,这里一定要用 dubbo包下的
//亲测 @Component 无用,不会启动客户端的 zookeeper
public class TicketServiceImpl implements ITicketService {
    @Override
    public String getTicket() {
        return "一张票";
    }
}

启动测试服务提供者是否正常

  1. 开启zookeeper

  2. 打开dubbo-admin实现监控(可略过,只是方便查看)

  3. 开启服务者
    这步测试了好久,刚开始是service层没有用@Service,改完了还不行 又换版本,最后清里idea的缓存重新运行就好了
    doubbo+zookeeper服务注册发现_其他
    消费服务

    1. 创建一个模块,实现服务提供者:consumer-server , 选择web依赖即可
    2. 引入pom依赖,同上
server.port=8002
# 谁消费了服务
dubbo.application.name=cunsumer-server
# 注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

UserServiceImpl.java
将provider-server下 ITicketService 拷贝至consumer-server下(interface的目录一定要对应)

@Service  //这里是spring下的
public class UserServiceImpl implements IUserService {
    @Reference   // dubbo包下,Pom坐标,可以定义路径相同的接口名
    ITicketService ticketService;
    
    @Override
    public void buyTicket() {
       String string = ticketService.getTicket();
        System.out.println("买到了" + string);
    }
}

测试

@SpringBootTest
class ConsumerServerApplicationTests {
    @Autowired
    IUserService userService;

    @Test
    void contextLoads() {
        userService.buyTicket();
    }
}

结果:
doubbo+zookeeper服务注册发现_apache_02

注:一定要开启 zookeeper服务,消费者引入提供者的接口类路径一定要和提供者的接口名一致,
doubbo+zookeeper服务注册发现_apache_03

【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

  1. 分享:
最后一次编辑于 2023年11月13日 0

暂无评论

推荐阅读
  TEZNKK3IfmPf   21天前   48   0   0 java
  TEZNKK3IfmPf   2024年05月31日   55   0   0 java
TEZNKK3IfmPf