springboot使用dubbo和zookeeper代码实例

springboot使用dubbo和zookeeper代码实例

这篇文章主要介绍了springboot使用dubbo和zookeeper代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

创建服务接口模块

接口工程只提供接口，不提供实现，在后面http://的提供者和消费者中使用

在使用接口的模块中只需要写具体实现类，避免了在每个模块中重复编写接口

在接口中引入依赖包

org.projectlombok

lombok

true

创建一个实体类,一定要实现Serializable接口，否则dubbo协议之间无法传输

@Data

@AllArgsConstructor

public class User implements Serializable {

private String name;

}

创建接口

public interface UserService {

List getAll();

List getAll2();

}

创建服务提供者

引入依赖

com.yls

common-api

1.0-SNAPSHOT

org.springframework.boot

spring-boot-starter

com.alibaba.boot

dubbo-spring-boot-starter

0.2.0

修改配置文件

#服务名称

dubbo.application.name=provider1

#注册中心地址

dubbo.registry.address=39.97.234.52:2181,39.97.234.52:2182,39.97.234.52:2183

#注册中心类型

dubbo.registry.protocol=zookeeper

#版本号

dubbo.application.version=3

# Dubbo Protocol

#协议名称

dubbo.protocol.name=dubbo

#服务暴露端口

dubbo.protocol.port=20880

实现服务接口

//暴露服务

//这里的@Service是Dubbo提供的，不是spring中的

//version必填

@Service(version = "${dubbo.application.version}")

@Component

public class UserImpl implements UserService {

@Override

public List getAll() {

User user1 = new User("张三");

User user2 = new User("lisi");

List list = Arrays.asList(user1, user2);

return list;

}

}

启动服务

//@EnableDubbo等价于在配置文件中配置dubbo.scan.base-packages

//扫描实现类所在的包，注册Bean

@EnableDubbo

@SpringBootApplication

public class ProviderApplication {

public static void main(String[] args) {

SpringApplication.run(ProviderApplication.class,args);

}

}

创建消费者

引入依赖

org.springframework.boot

spring-boot-starter-web

com.alibaba.boot

dubbo-spring-boot-starter

0.2.0

com.yls

common-api

1.0-SNAPSHOT

修改配置文bsKkqXFaC件

#注册中心

dubbo.registry.address=39.97.234.52:2181,39.97.234.52:2182,39.97.234.52:2183

dubbo.registry.protocol=zookeeper

#dubbo应用名称

dubbo.application.name=consumer1

实现消费接口

//服务消费者的Service是spring的

@Service

public class OrderImpl implements OrderService {

//使用dubbo提供的@Reference访问远程服务

//version对应服务提供者的version

@Reference(version = "3")

private UserService userService;

@Override

public List init() {

List list = userService.getAll();

list.forEach(item -> System.out.println(item.getName()));

return list;

}

}

创建controller

@Controller

public class OrderController {

@Autowired

private OrderService orderService;

@ResponseBody

@RequestMapping("/init")

public List init() {

return orderService.init();

}

}

启动服务消费者

@EnableDubbo

@SpringBootApplication

public class ConsumerApplication {

public static void main(String[] args) {

SpringApplication.run(ConsumerApplication.class, args);

}

}

dubbo相关补充

dubbo使用本地缓存方式，如果注册中心全部宕机，dubbo也能正常工作，就算没有注册中心，dubbo也能通过dubbo直连通信

//使用dubbo提供的@Reference访问远程服务

//version对应服务提供者的version

//url:如果没有注册中心，可以通过url配置服务提供者的dubbo协议端口，进行dubbo直连

@Reference(version = "3",url ="127.0.0.1:20880" )

private UserService userService;

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。