Dubbo+Spring基本整合（Zookeeper、Dubbo-Monitor-Simple、Dubbo-Admin）

梦里梦外; 2022-03-21 02:24 249阅读 0赞

# 启动Zookeeper和Dubbo-Admin #

参考：[https://blog.csdn.net/qq\_37598011/article/details/86685467][https_blog.csdn.net_qq_37598011_article_details_86685467]

# 启动Dubbo-Monitor-Simple #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70][]

进入后**执行mvn package命令**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 1][]

进入target目录

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 2][]

然后解压dubbo-monitor-simple-2.0.0-assembly.tar.gz这个压缩包

其目录如下：

![20190130092804863.png][]

进入conf目录中有dubbo.properties，这个文件是用来具体配置的：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 3][]

## 启动 ##

进入assembly.bin目录

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 4][]

执行**start.bat**文件

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 5][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 6][]

OK~

PS:如果想要修改这个端口号则修改配置文件的：**dubbo.jetty.port=9999**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 7][]

# Dubbo（服务提供者+服务消费者） #

## 基础公共部分 ##

一个用户类：

import java.io.Serializable;
    
    /**
    
     * @author zzf
     *
     */
    public class User implements Serializable {
    	
    	private Integer id;
        private String userAddress; //用户地址
        private String userId; //用户id
        private String consignee; //收货人
        private String phoneNum; //电话号码
        private String isDefault; //是否为默认地址    Y-是     N-否
        
        public User() {
    		super();
    		// TODO Auto-generated constructor stub
    	}
        
    	public User(Integer id, String userAddress, String userId, String consignee, String phoneNum,
    			String isDefault) {
    		super();
    		this.id = id;
    		this.userAddress = userAddress;
    		this.userId = userId;
    		this.consignee = consignee;
    		this.phoneNum = phoneNum;
    		this.isDefault = isDefault;
    	}
    	
    	public Integer getId() {
    		return id;
    	}
    	public void setId(Integer id) {
    		this.id = id;
    	}
    	public String getUserAddress() {
    		return userAddress;
    	}
    	public void setUserAddress(String userAddress) {
    		this.userAddress = userAddress;
    	}
    	public String getUserId() {
    		return userId;
    	}
    	public void setUserId(String userId) {
    		this.userId = userId;
    	}
    	public String getConsignee() {
    		return consignee;
    	}
    	public void setConsignee(String consignee) {
    		this.consignee = consignee;
    	}
    	public String getPhoneNum() {
    		return phoneNum;
    	}
    	public void setPhoneNum(String phoneNum) {
    		this.phoneNum = phoneNum;
    	}
    	public String getIsDefault() {
    		return isDefault;
    	}
    	public void setIsDefault(String isDefault) {
    		this.isDefault = isDefault;
    	}
    
    	@Override
    	public String toString() {
    		return "UserAddress [id=" + id + ", userAddress=" + userAddress + ", userId=" + userId + ", consignee="
    				+ consignee + ", phoneNum=" + phoneNum + ", isDefault=" + isDefault + "]";
    	}
        
    }

接口类：

订单服务类：

package com.dubbo.basics_interface.service;
    
    import java.util.List;
    
    import com.dubbo.basics_interface.dto.User;
    
    public interface OrderService {
    	
    	/**
    	 * 初始化订单
    	 * @param userId
    	 */
    	public List<User> initOrder(String userId);
    
    }

用户服务类：

package com.dubbo.basics_interface.service;
    
    import java.util.List;
    
    import com.dubbo.basics_interface.dto.User;
    
    /**
     * 用户服务
     * @author zzf
     *
     */
    public interface UserService {
    	
    	/**
    	 * 按照用户id返回所有的收货地址
    	 * @param userId
    	 * @return
    	 */
    	public List<User> getUserAddressList(String userId);
    
    }

此时该类的pom文件如下：

## 服务提供者 ##

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.dubbo</groupId>
    	<artifactId>service-provider</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>jar</packaging>
    
    	<name>service-provider</name>
    	<url>http://maven.apache.org</url>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>junit</groupId>
    			<artifactId>junit</artifactId>
    			<version>3.8.1</version>
    			<scope>test</scope>
    		</dependency>
    		
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>dubbo</artifactId>
    			<version>2.6.2</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.apache.curator</groupId>
    			<artifactId>curator-framework</artifactId>
    			<version>2.12.0</version>
    		</dependency>
                    
    		<dependency>
    			<groupId>com.dubbo</groupId>
    			<artifactId>basics-interface</artifactId>
    			<version>0.0.1-SNAPSHOT</version>
    		</dependency>
    	</dependencies>
    </project>

实现用户服务的接口：

package com.dubbo.service_provider.service.impl;
    
    import java.util.Arrays;
    import java.util.List;
    
    import org.springframework.stereotype.Component;
    
    import com.dubbo.basics_interface.dto.User;
    import com.dubbo.basics_interface.service.UserService;
    
    /* 
    * @author zzf 
    * @date 2019年1月29日 下午3:40:16 
    */
    @Component
    public class UserServiceImpl implements UserService{
    	public List<User> getUserAddressList(String userId) {
    		// TODO Auto-generated method stub
    		User address1 = new User(1, "XXXXXXX1", "1", "小A", "88888888888", "Y");
    		User address2 = new User(2, "XXXXXXX2", "2", "小B", "77777777777", "N");
    		User address3 = new User(3, "XXXXXXX3", "3", "小C", "99999999999", "Y");
    		return Arrays.asList(address1,address2,address3);
    	}
    
    }

创建src/main/resources目录并创建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://dubbo.apache.org/schema/dubbo"
    	xmlns:context="http://www.springframework.org/schema/context"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
    		http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
    		http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
    	
    	<context:component-scan base-package="com.dubbo.service_provider.service.impl"></context:component-scan>
    
    	
    	<dubbo:application name="service-provider"></dubbo:application>
    	
    	
    	
    	<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
    	
    	
    	<dubbo:protocol name="dubbo" port="22288"></dubbo:protocol>
    	
    	
    	<dubbo:service interface="com.dubbo.basics_interface.service.UserService" 
    		ref="userServiceImpl" ></dubbo:service>
    	
    	
    	<dubbo:monitor protocol="registry"></dubbo:monitor>
    </beans>

最后创建main方法测试：

package com.dubbo.service_provider;
    
    import java.io.IOException;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    /**
     * Hello world!
     *
     */
    public class App 
    {
        public static void main( String[] args ) throws IOException
        {
        	String a=new String("provider.xml");
        	ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext(a);
    		ioc.start();
    		
    		System.in.read();
        }
    }

运行如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 8][]

## 服务消费者 ##

pom文件跟服务提供者一致

实现订单服务类：

package com.dubbo.service_consumer.service.impl;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import com.dubbo.basics_interface.dto.User;
    import com.dubbo.basics_interface.service.OrderService;
    import com.dubbo.basics_interface.service.UserService;
    
    /* 
    * @author zzf 
    * @date 2019年1月29日 下午3:11:42 
    */
    @Service
    public class OrderServiceImpl implements OrderService{
    	
    	@Autowired
    	UserService userService;
    	
    	public List<User> initOrder(String userId) {
    		// TODO Auto-generated method stub
    		System.out.println("用户id："+userId);
    		//1、查询用户的收货地址
    		List<User> addressList = userService.getUserAddressList(userId);
    		for (User userAddress : addressList) {
    			System.out.println(userAddress);
    		}
    		return addressList;
    	}
    
    }

创建src/main/resources目录并创建consumer.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://dubbo.apache.org/schema/dubbo"
    	xmlns:context="http://www.springframework.org/schema/context"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
    		http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
    		http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    	
    	
    	<context:component-scan base-package="com.dubbo.service_consumer.service.impl"></context:component-scan>
    
    	<dubbo:application name="service-consumer"></dubbo:application>
    	
    	<dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
    	
    	
    	
    	
    	
    	
    	
    	
    	<dubbo:reference interface="com.dubbo.basics_interface.service.UserService" 
    		id="userService" >
    		
    	</dubbo:reference>
    		
    	
    	<dubbo:monitor protocol="registry"></dubbo:monitor>
    </beans>

创建main方法测试：

package com.dubbo.service_consumer;
    
    import java.io.IOException;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import com.dubbo.basics_interface.service.OrderService;
    
    /**
     * Hello world!
     *
     */
    public class App {
    	public static void main(String[] args) throws IOException {
    		ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
    
    		OrderService orderService = applicationContext.getBean(OrderService.class);
    
    		orderService.initOrder("2222222");
    		System.out.println("调用完成....");
    		System.in.read();
    	}
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 9][]

再看看监控中心：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 10][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 11][]

OK~

官网文档：[http://dubbo.apache.org/zh-cn/docs/user/quick-start.html][http_dubbo.apache.org_zh-cn_docs_user_quick-start.html]

[https_blog.csdn.net_qq_37598011_article_details_86685467]: https://blog.csdn.net/qq_37598011/article/details/86685467
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70]: /images/20220321/41ccbdbf7551450693373de36bfcf083.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 1]: /images/20220321/75c70a54da8d4a948a6250a53776ff2b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 2]: /images/20220321/8886ab7fb2534552b3f57e809c0ff060.png
[20190130092804863.png]: /images/20220321/b8252ea9777d4a48a2c1e42fc4ab412c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 3]: /images/20220321/03b73db3128b4719a63b52c96ff653f5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 4]: /images/20220321/9af6a670db684fba8385c61e82668438.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 5]: /images/20220321/1eee568b0863461385ffbb776e8f39d0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 6]: /images/20220321/2a5b8c28c5c843c9b48907db304d45bc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 7]: /images/20220321/5b91fb5e8be748bea63c7fc454119cf6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 8]: /images/20220321/45399326cf484698bb75417f42b23768.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 9]: /images/20220321/68e8e629aa524c9cbb5262dfa6c01cc8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 10]: /images/20220321/8dcf21b5acd2418fa8fd451c1838204d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NTk4MDEx_size_16_color_FFFFFF_t_70 11]: /images/20220321/fee61f8c397044feb3366c7cb2160134.png
[http_dubbo.apache.org_zh-cn_docs_user_quick-start.html]: http://dubbo.apache.org/zh-cn/docs/user/quick-start.html