• Dubbo+Zookeeper实现分布式布局
• • 加入Zookeeper
  • Dubbo
  • 编写provider代码（简单示例）
  • • 添加依赖
    • 代码
  • 编写consumer代码（简单示例）
  • • 加入依赖
    • 代码
  • 加入Dubbo管理控制台

Dubbo+Zookeeper实现分布式布局

加入Zookeeper

在服务器端使用docker 下载Zookeeper镜像

docker pull ovfftd6p.mirror.aliyuncs.com/library/zookeeper

下载完成后启动Zookeeper

docker run -name zk01 --restart always -d -p 2181:2181 {IMAGE ID}

使用 docker ps 查看是否启动成功

Dubbo

官方文档：http://dubbo.apache.org/
github：
https://github.com/apache/dubbo

https://github.com/apache/dubbo-spring-boot-project

https://github.com/apache/dubbo-spring-boot-project/blob/0.2.x/README_CN.md

Dubbo是什么？

• Dubbo是：
  • 一款分布式服务框架
  • 高性能和透明化的RPC远程服务调用方案
  • SOA服务治理方案
  • Dubbo每天为2千多个服务提供大于30亿次访问量支持，并被广泛应用于阿里巴巴集团的各成员站点以及别的公司的业务中。
    
    

编写provider代码（简单示例）

添加依赖

com.alibaba.bootdubbo-spring-boot-starter0.2.1.RELEASEcom.alibabadubbo2.6.5org.apache.curatorcurator-recipes2.12.0

代码

实体类

public class User implements Serializable {private int id;private String name;private int age;@Overridepublic String toString() {return "User{" +"id=" + id +", name='" + name + '\'' +", age=" + age +'}';}public int getId() {return id;}public void setId(int id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public int getAge() {return age;}public void setAge(int age) {this.age = age;}
}

服务接口

public interface UserService {public User getUserById(int id);
}

服务实现类

@Service
@com.alibaba.dubbo.config.annotation.Service
public class UserServiceImpl implements UserService {@Overridepublic User getUserById(int id) {User user = new User();user.setId(id);user.setAge(20);user.setName("zzm");return user;}
}

application.properties

server.port=8081spring.application.name=dubbo-provider-userdubbo.application.name=dubbo-provider-userdubbo.scan.base-packages=com.etc.servicedubbo.registry.address=zookeeper://192.168.88.128:2181

springboot启动类

@SpringBootApplication
@EnableDubbo
public class DemoproviderApplication {public static void main(String[] args) {SpringApplication.run(DemoproviderApplication.class, args);}}

执行springboot启动类

编写consumer代码（简单示例）

加入依赖

com.alibaba.bootdubbo-spring-boot-starter0.2.1.RELEASE

com.alibabadubbo2.6.5
org.apache.curatorcurator-recipes2.12.0

代码

实体类和服务接口 与provider一致

ConUserService

public interface ConUserService {public User getUserById(int id);
}

ConUserServiceImpl

@Service
public class ConUserServiceImpl implements ConUserService {@Referenceprivate UserService userService;@Overridepublic User getUserById(int id) {return userService.getUserById(1);}
}

UserController

@RestController
public class UserController {@Autowiredprivate ConUserService service;@GetMapping("user/{id}")public User getById(@PathVariable("id") int id){User userById = service.getUserById(id);return userById;}
}

执行springboot启动类

加入Dubbo管理控制台

自己封装了一个jar 可以直接使用

需要修改的地方

修改完后打开cmd 使用java -jar jar包