专栏首页波波烤鸭Dubbo02【搭建provider和consumer】

Dubbo02【搭建provider和consumer】

  本文来给大家介绍下基于Spring配置的方式来搭建dubbo中的服务提供端和消费端

provider和consumer的搭建

1.项目结构

  项目采用Maven聚合功能,共有三个模块,结构如下:

dubbo-common

dubbo-consumer

dubbo-provider

模块说明

模块

说明

dubbo-common

公共模块,用来存放服务提供者和消费则所需的所有的接口和pojo类,实现代码的复用,dubbo-provider和dubbo-consumer都需要引入这个包,所以我们需要先 mvn clean install

dubbo-provider

服务提供者

dubbo-consumer

服务消费者

2.具体实现

2.1dubbo-common

person.java

package com.bobo.pojo;

public class Person {

	private Integer id;
	
	private String name;

	public Integer getId() {
		return id;
	}

	public void setId(Integer id) {
		this.id = id;
	}

	public String getName() {
		return name;
	}

	@Override
	public String toString() {
		return "Person [id=" + id + ", name=" + name + "]";
	}

	public void setName(String name) {
		this.name = name;
	}
}

UserService.java 接口中定义

package com.bobo.service;

import com.bobo.pojo.Person;

public interface UserService {

	String sayHello(String name); 
	
    String testPojo(Person person);
}

2.2 provider

pom.xml 引入相关的依赖

<dependencies>
<!-- 依赖公共模块 -->
	<dependency>
		<groupId>com.bobo</groupId>
		<artifactId>dubbo-common</artifactId>
		<version>0.0.1-SNAPSHOT</version>
	</dependency>
	<!-- 引入Spring的依赖 -->
	<dependency>
		<groupId>org.springframework</groupId>
		<artifactId>spring-context</artifactId>
		<version>4.3.21.RELEASE</version>
	</dependency>
	<!-- 引入日志的依赖 -->
  	<dependency>
  		<groupId>org.slf4j</groupId>
  		<artifactId>slf4j-log4j12</artifactId>
  		<version>1.7.25</version>
  	</dependency>
 		<!-- 引入dubbo框架(服务端、客户端通用) -->
       <dependency>
           <groupId>com.alibaba</groupId>
           <artifactId>dubbo</artifactId>
           <version>2.5.3</version>
           <exclusions>
               <exclusion>
                   <artifactId>spring</artifactId>
                   <groupId>org.springframework</groupId>
               </exclusion>
           </exclusions>
       </dependency>
       <!-- 因为dubbo服务端需要注册服务到zk中,因此依赖zkClient包 -->
       <dependency>
           <groupId>com.github.sgroschupf</groupId>
           <artifactId>zkclient</artifactId>
           <version>0.1</version>
       </dependency>
 </dependencies>

Spring配置文件 在spring配置文件中设置dubbo的相关信息

<?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:context="http://www.springframework.org/schema/context"
    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://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-4.0.xsd 
    http://code.alibabatech.com/schema/dubbo
    http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!-- 提供方应用信息,用于计算依赖关系 -->
    <dubbo:application name="dubboProvider" />

    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <dubbo:registry protocol="zookeeper" 
    	address="192.168.88.171:2181,192.168.88.172:2181,192.168.88.173:2181"  />

    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />
    <!-- 启用monitor模块 -->
    <dubbo:monitor protocol="registry" />

    <bean id="userService" class="com.bobo.service.UserServiceImpl" />

    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="com.bobo.service.UserService" ref="userService"
        group="dubbo"  version="1.0.0" timeout="3000"/>
</beans>

zookeeper的配置方式如下:

<dubbo:registry address="zookeeper://192.168.88.171:2181" />

或者

<dubbo:registry protocol="zookeeper" address="192.168.88.171:2181" />

如果有多个ip地址

<dubbo:registry address="zookeeper://192.168.88.171:2181?backup=192.168.88.172:2181,192.168.88.173:2181"  />

或者

<dubbo:registry protocol="zookeeper" 
    	address="192.168.88.171:2181,192.168.88.172:2181,192.168.88.173:2181"  />

另外你还可以在同一个 Zookeeper 服务器上划分多个分组

<dubbo:registry id="registry1" protocol="zookeeper" address="10.20.153.10:2181" gr
oup="registry1" />
<dubbo:registry id="registry2" protocol="zookeeper" address="10.20.153.10:2181" gro
up="registry2" />

在同一个 Zookeeper 服务器上划分了两个分组,也就是会有两颗树目录,树根分别为 registry1 和 registry2。

UserServiceImpl 接口实现类

public class UserServiceImpl implements UserService {

	@Override
	public String sayHello(String name) {
		 //让当前当前线程休眠2s
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("-------"+name);
        return name+"----000"; 
	}

	@Override
	public String testPojo(Person person) {
		System.out.println(person.getName()+"/t"+person.getId());
		return "你好啊...";
	}

}

log4j.properties

log4j.rootLogger=INFO,A1
log4j.appender.A1=org.apache.log4j.ConsoleAppender
log4j.appender.A1.layout=org.apache.log4j.PatternLayout

测试启动

package com.bobo.test;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Test {

	public static void main(String[] args) throws InterruptedException {
		ApplicationContext ac = 
				new ClassPathXmlApplicationContext("applicationContext.xml");
		//挂起当前线程,如果没有改行代码,服务提供者进程会消亡,服务消费者就发现不了提供者了
        Thread.currentThread().join();
	}
}

服务已经成功注册到了zookeeper中

2.3 consumer

pom.xml 引入相关的依赖

<dependencies>
	<!-- 依赖公共模块 -->
	<dependency>
		<groupId>com.bobo</groupId>
		<artifactId>dubbo-common</artifactId>
		<version>0.0.1-SNAPSHOT</version>
	</dependency>
	<!-- 依赖Spring -->
	<dependency>
		<groupId>org.springframework</groupId>
		<artifactId>spring-context</artifactId>
		<version>4.3.21.RELEASE</version>
	</dependency>
	<!-- log4j的依赖 -->
	<dependency>
		<groupId>org.slf4j</groupId>
		<artifactId>slf4j-log4j12</artifactId>
		<version>1.7.25</version>
	</dependency>
	<!-- 引入dubbo框架(服务端、客户端通用) -->
	<dependency>
		<groupId>com.alibaba</groupId>
		<artifactId>dubbo</artifactId>
		<version>2.5.3</version>
		<exclusions>
			<exclusion>
				<artifactId>spring</artifactId>
				<groupId>org.springframework</groupId>
			</exclusion>
		</exclusions>
	</dependency>
	<!-- 因为dubbo服务端需要注册服务到zk中,因此依赖zkClient包 -->
       <dependency>
           <groupId>com.github.sgroschupf</groupId>
           <artifactId>zkclient</artifactId>
           <version>0.1</version>
       </dependency>
</dependencies>

Spring配置文件

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"    
     xmlns:context="http://www.springframework.org/schema/context"
     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://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-4.0.xsd 
    http://code.alibabatech.com/schema/dubbo
    http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

  	<!-- 消费方应用名,用于计算依赖关系,不是匹配条件,不要与提供方一样 -->    
    <dubbo:application name="dubboConsumer" />  
    <!-- 使用zookeeper注册中心暴露发现服务地址 -->    
    <dubbo:registry  protocol="zookeeper" 
    	address="192.168.88.171:2181,192.168.88.172:2181,192.168.88.173:2181" />  
       <!-- 启动monitor-->
    <dubbo:monitor protocol="registry" />        
      <!-- 生成远程服务代理,可以和本地bean一样使用demoService -->    
    <dubbo:reference id="userService" interface="com.bobo.service.UserService" 
    	group="dubbo" version="1.0.0" timeout="3000"/>    
</beans>

log4j.properties

log4j.rootLogger=INFO,A1
log4j.appender.A1=org.apache.log4j.ConsoleAppender
log4j.appender.A1.layout=org.apache.log4j.PatternLayout

TsetConsumer.java

package com.bobo.test;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.bobo.service.UserService;

public class TestConsumer {

	public static void main(String[] args) {
        ClassPathXmlApplicationContext ac = 
        		new ClassPathXmlApplicationContext("applicationContext.xml");
        final UserService demoService = (UserService) ac.getBean("userService");
        System.out.println(demoService.sayHello("哈哈哈"));
    }
}

测试输出

说明服务消费者已经正常调用了服务提供方的服务了!

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • IntelliJ IDEA(2019)Maven聚合工程实现dubbo入门案例

      maven和dubbo在现在来说都是非常火的技术,本文就来记录下IntelliJ IDEA中通过maven的聚合工程来实现dubbo的入门案例

    用户4919348
  • 好好编程-物流项目01【搭建maven工程】

      本项目采用maven聚合的方式搭建,如果对maven不是太熟悉请先复习下maven的内容.地址如下:

    用户4919348
  • mybatis和spring整合

    用户4919348
  • Dubbo(五) Dubbo入门demo——helloworld

    前言 前面我已经介绍了dubbo的一些基本工具和知识,让大家简单的了解了下RPC框架和Dubbo。接下来就是重点了,Dubbo的helloworld项目。 ? ...

    生活创客
  • Dubbo入门-简易配置

    想看分布式的东西好久了,目前的公司用不到,只能自己去网上找相关的,看到最多的Dubbo,于是趁着今天有时间自己照着一些教程自己配置了个基础的demo,顺便放出来...

    汐楓
  • IntelliJ IDEA(2019)Maven聚合工程实现dubbo入门案例

      maven和dubbo在现在来说都是非常火的技术,本文就来记录下IntelliJ IDEA中通过maven的聚合工程来实现dubbo的入门案例

    用户4919348
  • dubbo(提供者、消费者)基于java的实现

    1、安装好jdk、zookeeper以后可以尝试开发代码进行dubbo的学习和练习。

    别先生
  • Windows环境 springboot+dubbo+zookerper 实现相互调用

    windows环境springboot+dubbo+zookerper实现相互调用

    斯文的程序
  • Dubbo配置方式详解

    Dubbo 是一个分布式服务框架,致力于提供高性能和透明化的 RPC 远程服务调用方案,是阿里巴巴 SOA 服务化治理方案的核心框架,每天为 2,000+ 个服...

    陈树义
  • python + Mongodb小试

    很早就想接触一下NoSql了,苦于一直备考。考完FRM二级之后,开始有时间接触新的东西了。Mongdb的名字一听就比Redis有趣。

    钱塘小甲子

扫码关注云+社区

领取腾讯云代金券

玩转腾讯云 有奖征文活动