Dubbo基础实例

﹏ヽ暗。殇╰゛Y 2023-07-08 09:02 5阅读 0赞

##### （一）定义公共服务接口模块 #####

本次实例演示接口调用，消费者调用getUser(int id)方法获取远程服务数据创建公共接口项目dubbo-common-interface，创建实体类和接口，对外暴露

创建实体类，序列化

public class User implements Serializable { 
    
    	private static final long serialVersionUID = 1L;
    
    	private int id;
    	// 姓名
    	private String name;
    	// 年龄
    	private int age;
    
      /**省略setter和getter**/
    
    }

创建接口

public interface UserService { 
    
    	// 根据用户id，查询用户信息
    	User getUser(int id);
    }

##### （二）服务接口提供模块 #####

创建接口服务项目dubbo-provider，pom.xml需要引入dubbo-common-interface依赖，以使用对应的接口和实体类对象，还需要引入zookeeper依赖 ，dubbo依赖  
POM.XML参考如下：

<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.zhizuobiao.dubbo</groupId>
    	<artifactId>dubbo-provider</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<dependencies>
    		
    		<dependency>
    			<groupId>dubbo</groupId>
    			<artifactId>dubbo-common-interface</artifactId>
    			<version>0.0.1-SNAPSHOT</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>dubbo</artifactId>
    			<version>2.5.3</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>com.101tec</groupId>
    			<artifactId>zkclient</artifactId>
    			<version>0.10</version>
    		</dependency>
    	</dependencies>
    </project>

创建配置文件，配置如下dubbo-user-provider.xml

<?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="user-provider" />
    	
    	<dubbo:registry address="zookeeper://127.0.0.1:2181" />
    	
    	<dubbo:protocol name="dubbo" port="20880" />
    	
    	<dubbo:service interface="services.UserService"
    		ref="userService" />
    	
    	<bean id="userService" class="services.UserServiceImpl" />
    </beans>

解释：  
服务提供者应用名称：微服务相互调用和注册中心发现服务的唯一白鸥是  
注册中心地址：使用zookeeper作为注册中心，这里在Windows本地测试，所以是127.0.0.1  
不管是在Linux还是Windows其实配置都是一样，注意修改  
协议和端口：协议和当前服务提供者暴露给注册中心和消费者的端口  
指明提供服务的接口：接口调用与下面的服务实现类配合，消费调用接口，由服务实现类处理业务

创建接口实现类，对应配置文件中\[服务实现类\]

public class UserServiceImpl implements UserService { 
        //模拟业务处理
    	public User getUser(int id) { 
    		User user = new User();
    		user.setAge(30);
    		user.setId(id);
    		user.setName("Dubbo");
    		return user;
    	}
    }

##### （三）服务消费者模块 #####

创建服务消费者项目dubbo-consumer  
POM.XML文件如下：

<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.zhizuobiao.dubbo</groupId>
    	<artifactId>dubbo-consumer</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    
    
    	<dependencies>
    		
    		<dependency>
    			<groupId>dubbo</groupId>
    			<artifactId>dubbo-common-interface</artifactId>
    			<version>0.0.1-SNAPSHOT</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>dubbo</artifactId>
    			<version>2.5.3</version>
    		</dependency>
    
    		
    		<dependency>
    			<groupId>com.101tec</groupId>
    			<artifactId>zkclient</artifactId>
    			<version>0.10</version>
    		</dependency>
    	</dependencies>
    	
    </project>

配置文件

<?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="demo-consumer" />	
    	
    	<dubbo:registry address="zookeeper://127.0.0.1:2181" />
    	
    	<dubbo:reference id="userService"
    		interface="services.UserService" />
    
    </beans>

##### （四）测试 #####

由于注册中心使用了zookeeper，因此需要开启zookeeper服务，这里为了简便使用的是Windows下开启的zookeeper.为了可视化观察服务提供和消费，请开启ZooInspector工具  
1：进入Zookeeper下面的bin目录点击zkServer.cmd，启动服务  
2：进入ZooInspector/build, 当前目录打开CMD，输入命令如下，启动jar

java -jar zookeeper-dev-ZooInspector.jar //执行成功后，会弹出java ui client

3：在服务提供者项目创建测试类，开启服务

import java.io.IOException;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    /** * 运行服务提供者 */
    public class ProviderMain { 
    	public static void main(String[] args) throws IOException { 
    		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
    				new String[] {  "dubbo-user-provider.xml" });
    		// 加载
    		context.start();
    		System.out.println("服务发布成功 端口 20880");
    		// 让程序阻塞
    		System.in.read();
    	}
    }

备注：使用System.in.read();让程序阻塞目的在于保证服务提供者能够一直保持启动状态

4：在消费者项目下创建测试类，启动服务

import org.springframework.context.support.ClassPathXmlApplicationContext;
    import services.User;
    import services.UserService;
    import java.io.IOException;
    /** * 消费者 */
    public class ConsumerMain { 
    
        public static void main(String[] args) throws IOException { 
            // 消费者调用服务提供者
            // 获取返回数据
    
            ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
                    new String[]{ "dubbo-user-consumer.xml"});
            // 加载
            context.start();
            // 获取 远程服务代理对象
            UserService userService = (UserService) context.getBean("userService");
            // 调用方法
            User user = userService.getUser(1);
            // 打印结果
            System.out.println(user.getName());
            // 让程序阻塞
            System.in.read();
        }
    }

5：观察控制台输出是否能够收到服务提供者消息，观察Zookeeper可视化工具，是否有对应目录生成

![在这里插入图片描述][20200225170058550.png]

[20200225170058550.png]: https://img-blog.csdnimg.cn/20200225170058550.png