今天就跟大家聊聊有关dubbo与zookeeper怎么在springboot中使用,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
按需策划设计可以根据自己的需求进行定制,做网站、成都网站设计构思过程中功能建设理应排到主要部位公司做网站、成都网站设计的运用实际效果公司网站制作网站建立与制做的实际意义创建服务接口模块
接口工程只提供接口,不提供实现,在后面的提供者和消费者中使用
在使用接口的模块中只需要写具体实现类,避免了在每个模块中重复编写接口
在接口中引入依赖包
org.projectlombok lombok true
创建一个实体类,一定要实现Serializable接口,否则dubbo协议之间无法传输
@Data @AllArgsConstructor public class User implements Serializable { private String name; }
创建接口
public interface UserService { ListgetAll(); 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 ListgetAll() { 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
修改配置文件
#注册中心 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 Listinit() { 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 Listinit() { 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中使用有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联网站建设公司行业资讯频道,感谢大家的支持。
另外有需要云服务器可以了解下创新互联建站www.cdcxhl.com,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。