Dubbo消费者的消费服务

07-12 12:38 539浏览

举报 T字号

大字

中字

小字

1.新建一个maven工程consumers，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.roadjava</groupId>
  <artifactId>consumers</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <dependencies>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.6.0</version>
    </dependency>
    <dependency>
        <groupId>com.101tec</groupId>
        <artifactId>zkclient</artifactId>
        <version>0.10</version>
    </dependency>
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>4.0.1</version>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>fastjson</artifactId>
        <version>1.2.46</version>
    </dependency>
    <dependency>
        <groupId>log4j</groupId>
        <artifactId>log4j</artifactId>
        <version>1.2.17</version>
    </dependency>
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-api</artifactId>
        <version>1.7.25</version>
    </dependency>
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-lang3</artifactId>
        <version>3.4</version>
    </dependency>
    <dependency>
        <groupId>io.netty</groupId>
        <artifactId>netty-all</artifactId>
        <version>4.0.35.Final</version>
    </dependency>
</dependencies>
</project>

2.新建一个api接口：

package com.roadjava.service;
/**
 * 接口类
 * @author zhaodaowen
 *
 */
public interface TextService {
	/**
	 * 
	 * @param txt:一段字符串
	 * @return :返回txt里面的关键词
	 */
	 String getKeyWords(String txt);
}

这个接口我们注意看下和provider中是完全一样的。

3.在src/main/resources目录下新建consumers.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
       http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
       http://code.alibabatech.com/schema/dubbo 
       http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 <!-- 定义服务提供方provider的应用名称,这是你随便起的,能保证唯一即可, 在计算依赖关系的时候用的到，
    为了统一管理，最好和应用名称一样 -->
    <dubbo:application name="consumers"/>
 	<!-- 指定zookeeper的地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    <!-- 生成远程服务代理，可以和本地bean一样使用textService,check属性指定的启动的时候是否检查,
    	设置为false代表启动的时候不检查-->
    <dubbo:reference id="textService" check="false" 
     interface="com.roadjava.service.TextService"/>
</beans>

4.新建TestConsumers.java来进行消费：

package consumers.test; 
import java.io.IOException; 
import org.springframework.context.support.ClassPathXmlApplicationContext; 
import com.roadjava.service.TextService;  
public class TestConsumers {
	public static void main(String[] args) {
		ClassPathXmlApplicationContext ac = 
				new ClassPathXmlApplicationContext(new String[]{"consumers.xml"});
		ac.start();
		/*textService为consumers.xml中配置的名字：dubbo:reference id="textService"
		虽然consumers工程中没有TextService的实现类，但是dubbo的dubbo:reference标签帮我们
		生成了interface="com.roadjava.service.TextService"这个接口的代理，我们程序中真正
		使用的就是dubbo帮我们生成的代理对象*/
	   TextService ts = ac.getBean("textService", TextService.class);
	   	String keyWords = ts.getKeyWords("乐之者java用心去写教程");
	   	System.out.println(keyWords);
        try {
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }
        ac.close();
	}
}

执行结果：