dubbo zookeeper简单的provide 和cosumer

2024-08-22 21:32
文章标签 简单 dubbo zookeeper provide cosumer

本文主要是介绍dubbo zookeeper简单的provide 和cosumer，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

 

准备工作

 

1、两个mave项目，一个provider 一个cosumer，

 

2、搭建好spring

 

1、提供者

 

1、pom依赖

 

<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.wpb.dubbo</groupId>
<artifactId>dubbo-provide</artifactId>
<version>0.0.1-SNAPSHOT</version>

<properties>
<spring.version>4.1.3.RELEASE</spring.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aspects</artifactId>
<version>${spring.version}</version>
</dependency>

<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.4.10</version>
<exclusions>
<exclusion>
<artifactId>spring</artifactId>
<groupId>org.springframework</groupId>
</exclusion>
</exclusions>
</dependency>

<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.3</version>
</dependency>
</dependencies>
</project>

 

2、接口和实现类

 

1、接口

 


public interface DubboProvide {


void sayHello();
}

 

 

2、实现类

 


public class DubboProvideImpl implements DubboProvide {

 public void sayHello() {
 System.out.println("this is my first dubbo program");
 }

}

 

 

3、spring 配置dubbo zookeeper

 

1、<dubbo:application 给服务器起的名字

2、 <dubbo:registry用zookeeper注册服务中心暴露服务地址 –

3、 <dubbo:service 提供服务的接口，以及实现类进行注入（有点类似webservice）

 

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns="http://www.springframework.org/schema/beans" 
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
 xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 
 xsi:schemaLocation="http://www.springframework.org/schema/beans 
 http://www.springframework.org/schema/beans/spring-beans.xsd 
 http://code.alibabatech.com/schema/dubbo 
 http://code.alibabatech.com/schema/dubbo/dubbo.xsd 
 "> 
 <!-- 给dubbo服务者起个名 --> 
 <dubbo:application name="productor"/> 
 
 <!-- 用zookeeper注册服务中心暴露服务地址 --> 
 <dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181"/> 
 <!-- 暴露dubbo的通信端口 --> 
 <dubbo:protocol name="dubbo" port="20880"/> 
 
 <!-- 提供服务的实现类 --> 
 <bean id="bubboProdutor" class="com.dubbo.service.impl.DubboProvideImpl"></bean> 
 <!-- 给消费者提供服务的接口 --> 
 <dubbo:service ref="bubboProdutor" interface="com.dubbo.service.DubboProvide"></dubbo:service> 
 </beans>

 

4、加载这个spring配置文件

 

public class DubboProvideStart {


public static void main(String[] args) throws Exception { 
 ClassPathXmlApplicationContext cfg = new ClassPathXmlApplicationContext("classpath:config/ApplicationContextProducror.xml"); 
 
cfg.start();


SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
 Date date = new Date(); 
 System.out.println("provider service start time��"+sdf.format(date)); 
 
         System.in.read(); 
 } 
}

 

1、控制台查看

 

 

5、在dubbo-admin浏览器的提供者中会看到有一个provide

 

 

 

6、代码位置

 

 

2、消费者

 

1、pom依赖

 

<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.wpb.dubbo</groupId>
 <artifactId>dubbo-consumer</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 
 <properties>
 <spring.version>4.1.3.RELEASE</spring.version>
 </properties>
 <dependencies>
  <dependency>
 <groupId>com.wpb.dubbo</groupId>
 <artifactId>dubbo-provide</artifactId>
 <version>0.0.1-SNAPSHOT</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-context</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-beans</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-webmvc</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-jdbc</artifactId>
 <version>${spring.version}</version>
 </dependency>
 <dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-aspects</artifactId>
 <version>${spring.version}</version>
 </dependency>

  <dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>dubbo</artifactId>
 <version>2.4.10</version>
 <exclusions>
 <exclusion>
 <artifactId>spring</artifactId>
 <groupId>org.springframework</groupId>
 </exclusion>
 </exclusions>
 </dependency>

 <dependency>
 <groupId>com.101tec</groupId>
  <artifactId>zkclient</artifactId>
 <version>0.3</version>
 </dependency>
 </dependencies>
</project>

 

2、只要提供者的接口（可以通过将提供者制作成依赖jar，然后pom进行引入，也可以直接复制过来提供者的接口，笔者建议使用第一种）

 

 

3、spring配置

 

1、dubbo:reference <!-- 调用远程的接口 -->

 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" 
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
 xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 
 xsi:schemaLocation="http://www.springframework.org/schema/beans 
 http://www.springframework.org/schema/beans/spring-beans.xsd 
 http://code.alibabatech.com/schema/dubbo 
 http://code.alibabatech.com/schema/dubbo/dubbo.xsd 
 "> 
 
 <!-- 消费者名称 --> 
 <dubbo:application name="customer"/> 
 <!-- 用zookeeper注册服务中心发现服务地址 --> 
 <dubbo:registry protocol="zookeeoer" address="zookeeper://127.0.0.1:2181"/> 
 <!-- 调用远程的接口 --> 
 <dubbo:reference id="dubboProvider" interface="com.dubbo.service.DubboProvide"/> 
 
</beans>

 

4、加载配置文件，并main函数进行调用测试。

 

public class CustomerMain {

public static void main(String[] args) throws InterruptedException{ 
 ClassPathXmlApplicationContext cfig = new ClassPathXmlApplicationContext("classpath:config/ApplicationContextCustomer.xml"); 
 
DubboProvide test = (DubboProvide) cfig.getBean("dubboProvider");



System.out.println("consumer connect to service begin"); 
 test.sayHello(); 
 Thread.sleep(100000); 
 System.out.println("consumer connect to service end"); 
 } 
}

 

 

5、关照消费者端的控制台，发现没有结果，那当然不会有结果了，这个类似于webservice。会在提供者端打印结果

 

 

6、观察提供者端控制台

 

 

7、观察dubbo-admin浏览器

 

 

8、代码位置

 

这篇关于dubbo zookeeper简单的provide 和cosumer的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

原文地址:
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.chinasem.cn/article/1097447。

相关文章

Mysql表的简单操作(基本技能)

Mysql表的简单操作(基本技能)

《Mysql表的简单操作(基本技能)》在数据库中,表的操作主要包括表的创建、查看、修改、删除等,了解如何操作这些表是数据库管理和开发的基本技能,本文给大家介绍Mysql表的简单操作,感兴趣的朋友一起看... 目录3.1 创建表 3.2 查看表结构3.3 修改表3.4 实践案例：修改表在数据库中，表的操作主要
阅读更多...
Java使用Curator进行ZooKeeper操作的详细教程

Java使用Curator进行ZooKeeper操作的详细教程

《Java使用Curator进行ZooKeeper操作的详细教程》ApacheCurator是一个基于ZooKeeper的Java客户端库,它极大地简化了使用ZooKeeper的开发工作,在分布式系统... 目录1、简述2、核心功能2.1 CuratorFramework2.2 Recipes3、示例实践3
阅读更多...
springboot简单集成Security配置的教程

springboot简单集成Security配置的教程

《springboot简单集成Security配置的教程》：本文主要介绍springboot简单集成Security配置的教程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录集成Security安全框架引入依赖编写配置类WebSecurityConfig（自定义资源权限规则
阅读更多...
如何使用Python实现一个简单的window任务管理器

如何使用Python实现一个简单的window任务管理器

《如何使用Python实现一个简单的window任务管理器》这篇文章主要为大家详细介绍了如何使用Python实现一个简单的window任务管理器,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起... 任务管理器效果图完整代码import tkinter as tkfrom tkinter i
阅读更多...
C++中函数模板与类模板的简单使用及区别介绍

C++中函数模板与类模板的简单使用及区别介绍

《C++中函数模板与类模板的简单使用及区别介绍》这篇文章介绍了C++中的模板机制,包括函数模板和类模板的概念、语法和实际应用,函数模板通过类型参数实现泛型操作,而类模板允许创建可处理多种数据类型的类,... 目录一、函数模板定义语法真实示例二、类模板三、关键区别四、注意事项 ‌在C++中，模板是实现泛型编程
阅读更多...
使用EasyExcel实现简单的Excel表格解析操作

使用EasyExcel实现简单的Excel表格解析操作

《使用EasyExcel实现简单的Excel表格解析操作》：本文主要介绍如何使用EasyExcel完成简单的表格解析操作,同时实现了大量数据情况下数据的分次批量入库,并记录每条数据入库的状态,感兴... 目录前言固定模板及表数据格式的解析实现Excel模板内容对应的实体类实现AnalysisEventLis
阅读更多...
Java中数组转换为列表的两种实现方式(超简单)

Java中数组转换为列表的两种实现方式(超简单)

《Java中数组转换为列表的两种实现方式(超简单)》本文介绍了在Java中将数组转换为列表的两种常见方法使用Arrays.asList和Java8的StreamAPI,Arrays.asList方法简... 目录1. 使用Java Collections框架（Arrays.asList）1.1 示例代码1.
阅读更多...
Java8需要知道的4个函数式接口简单教程

Java8需要知道的4个函数式接口简单教程

《Java8需要知道的4个函数式接口简单教程》：本文主要介绍Java8中引入的函数式接口,包括Consumer、Supplier、Predicate和Function,以及它们的用法和特点,文中... 目录什么是函数是接口？Consumer接口定义核心特点注意事项常见用法1.基本用法2.结合andThen链
阅读更多...
C++初始化数组的几种常见方法(简单易懂)

C++初始化数组的几种常见方法(简单易懂)

《C++初始化数组的几种常见方法(简单易懂)》本文介绍了C++中数组的初始化方法,包括一维数组和二维数组的初始化,以及用new动态初始化数组,在C++11及以上版本中,还提供了使用std::array... 目录1、初始化一维数组1.1、使用列表初始化（推荐方式）1.2、初始化部分列表1.3、使用std::
阅读更多...
redis群集简单部署过程

redis群集简单部署过程

《redis群集简单部署过程》文章介绍了Redis,一个高性能的键值存储系统,其支持多种数据结构和命令,它还讨论了Redis的服务器端架构、数据存储和获取、协议和命令、高可用性方案、缓存机制以及监控和... 目录Redis介绍1. 基本概念2. 服务器端3. 存储和获取数据4. 协议和命令5. 高可用性6.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2