正文

Docker+Dubbo+Zookeeper实现RPC远程调用

IP云
IP云V管理员/4 阅读
06/19
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

Docker+Dubbo+Zookeeper

1.安装Docker

1.1卸载旧版本的Docker

//如果Docker处于与运行状态 未运行可跳过
[root@MrADiao ~]# systemctl stop docker//如果Docker设置了开机自启 需先删除 没有设置可自行跳过
[root@MrADiao ~]# systemctl diable docker
//卸载docker-ce
[root@MrADiao ~]# yum remove docker-ce//删除注册表 文件夹
[root@MrADiao ~]# rm -rf /var/lib/docker

1.2.安装新版本的Docker

1、检查内核版本，必须是3.10及以上
[root@MrADiao ~]# uname -r2.安装依赖包
[root@MrADiao ~]# yum install -y yum-utils device-mapper-persistent-data lvm23.添加docker软件包源
[root@MrADiao ~]#yum-config-manager --add-repo https://download.docker.com/linux/centos/docker-ce.repo4、安装docker
[root@MrADiao ~]# yum install docker-ce5、输入y确认安装6.查看是否安装成功
[root@MrADiao ~]# docker version
或者
[root@MrADiao ~]# docker -v7、启动docker
[root@MrADiao ~]# systemctl start docker 8.设置docker开机自启
[root@MrADiao ~]#systemctl enable docker

可参考Docker官方文档：https://docs.docker.com/install/linux/docker-ce/centos/

1.3.docker常用命令

  • 镜像操作命令

操作命令说明
检索docker search 关键字 eg：docker search redis我们经常去docker hub上检索镜像的详细信息，如镜像的TAG。
拉取docker pull 镜像名:tag:tag是可选的，tag表示标签，多为软件的版本，默认是latest
列表docker images查看所有本地镜像
删除docker rmi image-id删除指定的本地镜像

  • 容器操作命令

操作命令说明
运行docker run --name container-name -d image-nameeg:docker run –name myredis –d redis--name：自定义容器名
-d：后台运行
image-name:指定镜像模板
列表docker ps查看运行中的容; 加上-a；可以查看所有容器
停止docker stop 容器Id删除指定的容器
启动docker start 容器id启动容器
删除docker rm 容器id删除一个容器
端口映射docker run -d -p 8888:8080 tomcat-d：后台运行
-p: 将主机的端口映射到容器的一个端口 主机端口:容器内部的端口
容器日志docker logs container-name/container-id查看容器的日志

2.Docker中安装Zookeeper

2.1.从Docker Hub中获取zookeeper镜像

[root@MrADiao ~]# docker pull zookeeper

2.2.启动zookeeper

[root@MrADiao ~]# docker run --name myzookeeper -p 2181:2181 --restart always -d zookeeper //-p指定端口启动 :前的端口是linux虚拟机的端口 :后的端口是指docker容器的端口 2181:2181意思是指 把linux系统的2181端口映射到docker容器的2181端口

3.zookeeper+dubbo简单代码实现

3.1创建服务端项目(provider-ticket)

首先创建一个SpringBoot项目

3.1.1Pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion><groupId>com.adiao</groupId>
<artifactId>provider-ticket</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging><name>provider-ticket</name>
<description>Demo project for Spring Boot</description><parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.12.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent><properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties><dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.1.0</version>
</dependency><!--引入zookeeper的客户端工具-->
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency><dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies><build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>

3.1.2 application.properties

dubbo.application.name=provider-ticketdubbo.registry.address=zookeeper://部署zookeeper服务器IP:2181dubbo.scan.base-packages=com.adiao.ticket.serviceserver.port=8081

3.1.3创建一个TicketService

package com.adiao.ticket.service;public interface TicketService { public String getTicket();
}

3.1.4实现TicketService

package com.adiao.ticket.service;import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;@Component
@Service
public class TicketServiceImpl implements TicketService {
@Override
public String getTicket() {
return "《厉害了，我的国》";
}
}

注意：@Service注解是dubbo下的，作用是将服务发布出去

3.2创建调用方

3.2.1创建调用方项目(consumer-user)

首先创建一个SpringBoot项目

3.2.2 pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion><groupId>com.adiao</groupId>
<artifactId>consumer-user</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging><name>consumer-user</name>
<description>Demo project for Spring Boot</description><parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.12.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent><properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties><dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency><dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.1.0</version>
</dependency><!--引入zookeeper的客户端工具-->
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency><dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies><build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build></project>

3.2.3application.properties

dubbo.application.name=consumer-userdubbo.registry.address=zookeeper://部署zookeeper服务器IP:2181server.port=8082

3.2.3 创建与被调用放一样的Service

package com.adiao.ticket.service;public interface TicketService { public String getTicket();
}

3.2.4创建一个调用方自己的Service

package com.adiao.user.service;import com.alibaba.dubbo.config.annotation.Reference;
import com.adiao.ticket.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);
}
}

3.3测试

在main/test/java/下创建测试类，一定要确保被调用方 也就是provider-ticket处于运行状态

package com.adiao.user;import com.adiao.user.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();
}}