Spring整合dubbo

浅浅的花香味﹌ 2022-09-09 15:56 177阅读 0赞

整合spring+dubbo+zookeeper

zookeeper相关安装配置跳过。

# 1、接口项目（dubbo-interface） #

## **接口：UserService ** ##

@Path("/user")
    public interface UserService {
    	@GET
    	@Path("/getUser/{id : \\d+}")
    	@Consumes({ MediaType.APPLICATION_JSON })
    	public String getUser(@PathParam("id") Integer id);
    }

## **dubbo-interface对外的pom依赖：** ##

<dependency>
        <groupId>com.dubbo.interface</groupId>
        <artifactId>dubbo-interface</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </dependency>

# **2、生产者项目(dubbo-provider)** #

**     **   **备注：**生产者负责接口的对外暴露

## **接口实现类** **UserServiceImpl****：** ##

public class UserServiceImpl implements UserService {
    	public String getUser(Long userId) {
    		System.out.println("###生产者服务接受参数开始userId:" + userId);
    		if (userId == 1) {
    			return "张三";
    		}
    		if (userId == 2) {
    			return "李四";
    		}
    		System.out.println("###生产者服务接受参数结束###");
    		return "未找到用户...";
    	}
    }

## **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="dubbox-provider" />
    	
    	<dubbo:registry address="zookeeper://127.0.0.1:2181" />
    	
    	<dubbo:protocol name="rest" port="8081" />
    	
    	<dubbo:service interface="com.***.service.UserService" ref="userService" />
    
    	
    	<bean id="userService" class="com.***.service.impl.UserServiceImpl" />
    </beans>

## **启动服务** ##

public class MemberServer {
    
    	public static void main(String[] args) throws IOException {
    		ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("provider.xml");
    		applicationContext.start();
    		System.out.println("生产者服务启动成功...");
    		System.in.read();
    	}
    
    }

## ** pom文件引入依赖** ##

<！-- 其它依赖   省略  -->
    .................
    
    <dependency>
        <groupId>com.dubbo.interface</groupId>
        <artifactId>dubbo-interface</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </dependency>
    
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>***</version>
    </dependency>
    
    <！-- 引入zookeeper的依赖   省略  -->

**生产者对外暴露的是接口，而非接口的实现类**

# 3、消费者(dubbo-consumer) #

## 远程调用 ##

public class OrderService {
    	public static void addOrder() {
    		ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
    		applicationContext.start();
    		System.out.println("开始调用生产者服务");
    		UserService userService=(UserService) applicationContext.getBean("userService");
    		String userName = userService.getUser(1l);
    		System.out.println("结束调用生产者服务,userName:" + userName);
    	}
    	public static void main(String[] args) {
    		addOrder();
    	}
    }

## **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://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="consumer" />
    	
    	<dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181" />
    	
    	<dubbo:reference id="userService" interface="com.***.service.UserService" />
    </beans>

## **pom文件引入依赖:** ##

以上就是spring+dubbo的简单整合。

dubbo-interface   只提供接口

dubbo-provider    生产者 实现dubbo-interface,并对外发布dubbo-interface接口服务

dubbo-consumer  消费者   对dubbo-provider发布的dubbo-interface接口服务  进行远程调用

然后附上  dubbo-admin 管理平台  做简单了解 ：[https://blog.csdn.net/qq\_35044419/article/details/120044815][https_blog.csdn.net_qq_35044419_article_details_120044815]

[https_blog.csdn.net_qq_35044419_article_details_120044815]: https://blog.csdn.net/qq_35044419/article/details/120044815