Dubbo简单配置使用
添加依赖在Maven的pom.xml文件中添加dubbo依赖com.github.sgroschupfzkclientorg.apache.zookeeperzookeepercom.alibabadubbospringorg.springframework
·
添加依赖
在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>
<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" />
<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服务接口,消费者需定义与服务提供方一样的接口,这样远程服务代理才能发现该接口。
开放原子开发者工作坊旨在鼓励更多人参与开源活动,与志同道合的开发者们相互交流开发经验、分享开发心得、获取前沿技术趋势。工作坊有多种形式的开发者活动,如meetup、训练营等,主打技术交流,干货满满,真诚地邀请各位开发者共同参与!
更多推荐
已为社区贡献1条内容
所有评论(0)