专栏首页数据分析与挖掘springboot分布式之整合zookeeper和dubbo

springboot分布式之整合zookeeper和dubbo

1、docker安装zookeeper

sudo docker pull zookeeper:3.4.11

sudo docker run --name zoopker01 -p 2181:2181 --restart always -d zookeeper:3.4.11

sudo docker ps -a

2、新建一个空项目,再分别新建两个module,一个是provider-ticket,一个是consumer-user

建好之后建立如下目录及文件:

(1) 首先分别将相关依赖导入到provider-ticket和consumer-user的pom.xml中

        <!--引入dubbo-->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.1.0</version>
        </dependency>
        <!--引入zookeeper-->
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>

(2)配置相关信息

在provider-ticker中application.properties

#提供者名称
dubbo.application.name=provider-ticket
#注册中心地址
dubbo.registry.address=zookeeper://192.168.124.22:2181
#将哪个包的服务发送出去
dubbo.scan.base-packages=com.gong.com.gong.providerticket.service

在consumer-user中application.properties

dubbo.application.name=consumer-user
dubbo.registry.address=zookeeper://192.168.124.22:2181

(3)在provider-ticker中的com.gong.providerticjet下的service.TicketService

package com.gong.providerticket.service;

public interface TicketService {
    public String getTicket();
}

service.TicketServiceImpl

package com.gong.providerticket.service;

import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

@Component
@Service
public class TicketServieImpl implements TicketService {

    @Override
    public String getTicket() {
        return "囧妈";
    }
}

这里的@Service注解注意是dubbo包里面的。

在provider-ticket主入口加上EnableDubbo注解。

然后我们将com.gong.providerticket.service.TicketService拷贝一份到consumer-user下,注意包名要对应。

接着就可以进行测试了:

UserService.java

package com.gong.consumeruser.service;

import com.alibaba.dubbo.config.annotation.Reference;
import com.gong.providerticket.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);
    }
}

这里的@Service是springboot中的。

最后是在ConsumerUserApplicationTests.java

package com.gong.consumeruser;

import com.gong.consumeruser.service.UserService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class ConsumerUserApplicationTests {

    @Autowired
    UserService userService;

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

}

3、进行测试

首先运行provider-ticket项目。然后再运行ConsumerUserApplicationTests.java中的contextLoads方法:

在consumer-user中成功调用了provider-ticket中的TicketServiceImpl.java中的方法。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 【猫狗数据集】对一张张图像进行预测(而不是测试集)

    链接:https://pan.baidu.com/s/1l1AnBgkAAEhh0vI5_loWKw 提取码:2xq4

    绝命生
  • springmvc之异常处理DefaultHandlerExceptionResolver

    这种特定的异常是DefaultHandlerExceptionResolver进行处理的。

    绝命生
  • 【python实现卷积神经网络】激活层实现

    代码来源:https://github.com/eriklindernoren/ML-From-Scratch

    绝命生
  • Dubbo属性覆盖策略(10)

    设置dubbo.protocol.port=20880,如果虚拟机参数传入优先级最高,如果虚拟机参数没有传入,XML和Spring boot的Applicati...

    桑鱼
  • 云计算是趋势 不久将来或将深入到各个领域

    智能化决定是目前消费电子领域的主流趋势,所有的产品只要能通电,基本上就都可以跟智能扯上关系。不说手机,电视这些主流产品,就连冰箱,洗衣机,空气净化器这些家居产品...

    静一
  • Dubbo-admin无法显示Group分组信息以及是否可以显示多个分组

    在首次使用Dubbo的时候,我们可能都会使用Dubbo-admin来监控服务的提供者和消费者,但是在自己的生产者成功运行的时候,在Dubbo-admin却看不到...

    MonroeCode
  • OCP-052考试题库汇总(16)-CUUG内部解答版

    Which three are true about AWR snapshots?

    用户5892232
  • dubbo服务的发布和调用

    用户2146856
  • iOS开发之地图与定位

      无论是QQ还是微信的移动客户端都少不了定位功能,之前在微信demo中没有添加定位功能,今天就写个定位的小demo来了解一下定位和地图的东西。地图和定位看上去...

    lizelu
  • Scrapy存入MySQL

    之前利用Scrapy爬取的数据,都是写入在json文件中,现在需要写入到mysql中。

    py3study

扫码关注云+社区

领取腾讯云代金券