添加依赖


在Maven的pom.xml文件中添加dubbo依赖

<span style="font-size:14px;"><dependency>
			<groupId>com.github.sgroschupf</groupId>
			<artifactId>zkclient</artifactId>
		</dependency>
		<dependency>
			<groupId>org.apache.zookeeper</groupId>
			<artifactId>zookeeper</artifactId>
		</dependency>
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>dubbo</artifactId>
			<exclusions>
				<exclusion>
					<artifactId>spring</artifactId>
					<groupId>org.springframework</groupId>
				</exclusion>
			</exclusions>
		</dependency></span>


服务提供者

定义服务接口: (该接口需单独打包,在服务提供方和消费方共享)

DemoService.java

package com.alibaba.dubbo.demo;

public interface DemoService {
 
    String say(String name);
 
}

服务提供方实现接口:(对服务消费方隐藏实现)

package com.alibaba.dubbo.demo.provider;
 
import com.alibaba.dubbo.demo.DemoService;
@Service
public class DemoServiceImpl implements DemoService {
 
    public String say(String name) {
        return "Hello " + name;
    }
 
}

服务提供者xml配置文件

Dubbo采用全Spring配置方式,透明化接入应用,对应用没有任何API侵入,只需用Spring加载Dubbo的配置即可,Dubbo基于Spring的Schema扩展进行加载

module-provider.xml
1.配置Spring注解识别器
<context:component-scan base-package="com.alibaba.dubbo.demo.provider" />

2. 配置dubbo注解识别处理器,不指定包名的话会在spring bean中查找对应实例的类配置了dubbo注解的
<dubbo:annotation package="com.bjhy.platform.statics.provider" />

3.配置应用名(提供方应用信息,用于计算依赖关系)
 <dubbo:application name="platform-demo"  />

4. 配置注册中心,通过group指定注册中心分组,可通过register配置是否注册到该注册中心以及subscribe配置是否从该注册中心订阅
可以使用multicast广播注册中心暴露服务地址
<dubbo:registry address="multicast://224.5.6.7:1234" />
也可以使用zookeeper分布式应用程序协调服务
<dubbo:registry protocol="zookeeper" address="192.168.0.2:1111" />

5. 配置服务协议,不指定或者指定非法IP的情况下会绑定在0.0.0.0
 <!-- 用dubbo协议在20880端口暴露服务 -->

加载Spring配置

import org.junit.runner.RunWith;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath*:META-INF/spring/module-*.xml")
public class Provider{

	public static void main(String[] args) throws Exception {
		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath*:META-INF/spring/module-*.xml");
		context.start();
		System.out.println("服务已启动****");
		System.in.read();
	}
	
}

服务消费者 xml配置文件

module-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">
     
    <context:component-scan base-package="com.alibaba.dubbo.demo.consumer" />
    <!-- 消费方应用名,用于计算依赖关系,不是匹配条件,不要与提供方一样 -->
    <dubbo:application name="consumer-app"  />
 
   <!-- 使用zookeeper广播注册中心暴露发现服务地址 -->
   <dubbo:registry protocol="zookeeper" address="192.168.0.2:1111" />
 
 
</beans>

加载Spring配置,通过使用Spring IoC依赖注入 例如:
@Autowired
private DemoService demoService 

 demoService.say("xiaowen")
当然DemoService服务接口,消费者需定义与服务提供方一样的接口,这样远程服务代理才能发现该接口。






Logo

开放原子开发者工作坊旨在鼓励更多人参与开源活动,与志同道合的开发者们相互交流开发经验、分享开发心得、获取前沿技术趋势。工作坊有多种形式的开发者活动,如meetup、训练营等,主打技术交流,干货满满,真诚地邀请各位开发者共同参与!

更多推荐