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中的方法。
- C#执行XSL转换
- javascript:算法笔记
- spring boot 登录注册 demo (一)
- linux学习:CentOS、Mac上SSH的设置以及SceureCRT中的文件上传下载
- 中关村成为北京“高精尖”产业发展主阵地
- jquery-barcode:js实现的条码打印
- 页面json 格式化+颜色高亮
- Python 里 and、or 的计算规则
- Python中赋值、浅拷贝与深拷贝
- git 简易使用说明
- 开发篇-MySQL分区(一)
- Establishing SSL connection without server's identity verification is not recommended. According to
- Django-认证系统
- javascript:双链表-插入排序
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释