今天就跟大家聊聊有关dubbo与zookeeper怎么在springboot中使用,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
创建服务接口模块
接口工程只提供接口,不提供实现,在后面的提供者和消费者中使用
在使用接口的模块中只需要写具体实现类,避免了在每个模块中重复编写接口
在接口中引入依赖包
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
创建一个实体类,一定要实现Serializable接口,否则dubbo协议之间无法传输
@Data
@AllArgsConstructor
public class User implements Serializable {
private String name;
}
创建接口
public interface UserService {
List<User> getAll();
List<User> getAll2();
}
创建服务提供者
引入依赖
<!--引入创建的接口服务-->
<dependency>
<groupId>com.yls</groupId>
<artifactId>common-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!--由于服务提供者不是web项目
,只需引入spring-boot-starter,不用引入spring-boot-starter-web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!--dubbo-->
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.2.0</version>
</dependency>
修改配置文件
#服务名称
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<User> getAll() {
User user1 = new User("张三");
User user2 = new User("lisi");
List<User> 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);
}
}
创建消费者
引入依赖
<!--消费者是web项目-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--dubbo-->
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.2.0</version>
</dependency>
<!--引入创建的接口服务-->
<dependency>
<groupId>com.yls</groupId>
<artifactId>common-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
修改配置文件
#注册中心
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<User> init() {
List<User> 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<User> 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;
看完上述内容,你们对dubbo与zookeeper怎么在springboot中使用有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注亿速云行业资讯频道,感谢大家的支持。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。