当前位置： 移动技术网 > IT编程>开发语言>Java > Dubbo搭建HelloWorld-搭建服务提供者与服务消费者并完成远程调用(附代码下载)

Dubbo搭建HelloWorld-搭建服务提供者与服务消费者并完成远程调用(附代码下载)

2019年12月24日  | 移动技术网IT编程  | 我要评论

场景

dubbo简介与基本概念：

https://blog.csdn.net/badao_liumang_qizhi/article/details/103555224

dubbo环境搭建-zookeeper注册中心：

https://blog.csdn.net/badao_liumang_qizhi/article/details/103555470

dubbo环境搭建-管理控制台dubbo-admin实现服务监控：

https://blog.csdn.net/badao_liumang_qizhi/article/details/103624846

在上面搭建好zookeeper注册中心和管理控制台dubbo-admin搭建后，实现helloworld程序完成基本入门。

注：

博客：

关注公众号
霸道的程序猿
获取编程相关电子书、教程推送与免费下载。

实现

为了解决依赖问题与实现微服务的概念，下面需要新建三个maven project

gmall-interface 用来作为公共依赖，存放公共接口和公共bean等。

uesr-service-provider 搭建服务提供者

order-service-consumer 搭建服务消费者

新建公共接口程序

打开eclipse-新建maven project

 

 

输入相关坐标信息，后面两个项目过程也是如此。

 

 

 

然后在项目下新建包com.badao.gmall

然后再新建bean包和service包

bean中新建useraddress实体类

package com.badao.gmall.bean;

import java.io.serializable;

/**
 * 用户地址
 * @author badao
 *
 */
public class useraddress implements serializable {
 
 private integer id;
    private string useraddress; //用户地址
    private string userid; //用户id
    private string consignee; //收货人
    private string phonenum; //电话号码
    private string isdefault; //是否为默认地址    y-是     n-否
    
    public useraddress() {
  super();
  // todo auto-generated constructor stub
 }
    
 public useraddress(integer id, string useraddress, string userid, string consignee, string phonenum,
   string isdefault) {
  super();
  this.id = id;
  this.useraddress = useraddress;
  this.userid = userid;
  this.consignee = consignee;
  this.phonenum = phonenum;
  this.isdefault = isdefault;
 }
 
 public integer getid() {
  return id;
 }
 public void setid(integer id) {
  this.id = id;
 }
 public string getuseraddress() {
  return useraddress;
 }
 public void setuseraddress(string useraddress) {
  this.useraddress = useraddress;
 }
 public string getuserid() {
  return userid;
 }
 public void setuserid(string userid) {
  this.userid = userid;
 }
 public string getconsignee() {
  return consignee;
 }
 public void setconsignee(string consignee) {
  this.consignee = consignee;
 }
 public string getphonenum() {
  return phonenum;
 }
 public void setphonenum(string phonenum) {
  this.phonenum = phonenum;
 }
 public string getisdefault() {
  return isdefault;
 }
 public void setisdefault(string isdefault) {
  this.isdefault = isdefault;
 }
    
   


}

 

然后在service包下新建两个公共接口类

 

 

orderservice.java

package com.badao.gmall.service;

import java.util.list;

import com.badao.gmall.bean.useraddress;

public interface orderservice {
 
 /**
  * 初始化订单
  * @param userid
  */
 public list<useraddress> initorder(string userid);

}

该接口声明一个初始化订单的方法。

userservice.java

package com.badao.gmall.service;

import java.util.list;

import com.badao.gmall.bean.useraddress;

/**
 * 用户服务
 * @author badao
 *
 */
public interface userservice {
 
 /**
  * 按照用户id返回所有的收货地址
  * @param userid
  * @return
  */
 public list<useraddress> getuseraddresslist(string userid);

}

 

该接口提供获取所有收获地址的方法的声明

新建服务提供者程序

参照上面流程，新建user-service-provider

然后在pom.xml中引入上面公共接口的依赖

  <dependency>
   <groupid>com.badao.gmall</groupid>
   <artifactid>gmall-interface</artifactid>
   <version>0.0.1-snapshot</version>
  </dependency>

 

然后还要引入dubbo以及zookeeper的依赖

 

 <!-- 引入dubbo -->
  <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
  <dependency>
   <groupid>com.alibaba</groupid>
   <artifactid>dubbo</artifactid>
   <version>2.6.2</version>
  </dependency>
  <!-- 注册中心使用的是zookeeper，引入操作zookeeper的客户端端 -->
  <dependency>
   <groupid>org.apache.curator</groupid>
   <artifactid>curator-framework</artifactid>
   <version>2.12.0</version>
  </dependency>

 

完整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.badao.gmall</groupid>
  <artifactid>user-service-provider</artifactid>
  <version>0.0.1-snapshot</version>
  <dependencies>
  <dependency>
   <groupid>com.badao.gmall</groupid>
   <artifactid>gmall-interface</artifactid>
   <version>0.0.1-snapshot</version>
  </dependency>
  <!-- 引入dubbo -->
  <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
  <dependency>
   <groupid>com.alibaba</groupid>
   <artifactid>dubbo</artifactid>
   <version>2.6.2</version>
  </dependency>
  <!-- 注册中心使用的是zookeeper，引入操作zookeeper的客户端端 -->
  <dependency>
   <groupid>org.apache.curator</groupid>
   <artifactid>curator-framework</artifactid>
   <version>2.12.0</version>
  </dependency>
 </dependencies>
</project>

 

在项目下新建service.impl包，包下新建实现类

package com.badao.gmall.service.impl;

import java.util.arrays;
import java.util.list;

import com.badao.gmall.bean.useraddress;
import com.badao.gmall.service.userservice;

 

public class userserviceimpl implements userservice {

 public list<useraddress> getuseraddresslist(string userid) {
  
  // todo auto-generated method stub
  useraddress address1 = new useraddress(1, "霸道流氓气质", "1", "李老师", "123456789", "y");
  useraddress address2 = new useraddress(2, "公众号：霸道的程序猿）", "1", "王老师", "987654321", "n");
  return arrays.aslist(address1,address2);
 }

}

 

然后按照其官方指示，新建配置文件并配置服务提供者

 

 

在src/main/resource下新建配置文件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://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
  http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

 <!-- 1、指定当前服务/应用的名字（同样的服务名字相同，不要和别的服务同名） -->
 <dubbo:application name="user-service-provider"></dubbo:application>
 
 <!-- 2、指定注册中心的位置 两种方式 -->
 <!-- <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry> -->
 <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>
 
 <!-- 3、指定通信规则（通信协议？通信端口） -->
 <dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>
 
 <!-- 4、暴露服务   ref：指向服务的真正的实现对象 -->
 <dubbo:service interface="com.badao.gmall.service.userservice" 
  ref="userserviceimpl" timeout="1000" version="1.0.0">
  <dubbo:method name="getuseraddresslist" timeout="1000"></dubbo:method>
 </dubbo:service>
 
 <!--统一设置服务提供方的规则  -->
 <dubbo:provider timeout="1000"></dubbo:provider>
 
 <bean id="userserviceimpl" class="com.badao.gmall.service.impl.userserviceimpl"></bean>
 
</beans>

 

然后在com.badao.gmall包下新建mainapplication.java

读取配置文件并暴露服务。

package com.badao.gmall;

import java.io.ioexception;

import org.springframework.context.applicationcontext;
import org.springframework.context.support.classpathxmlapplicationcontext;

public class mainapplication {
 
 public static void main(string[] args) throws ioexception {
  classpathxmlapplicationcontext ioc = new classpathxmlapplicationcontext("provider.xml");
  ioc.start();
  system.in.read();
 }

}

 

搭建服务消费者程序

参照上面流程新建order-service-consumer服务消费者程序

在pom.xml中添加公共接口依赖以及dubbo和zookeeper相关依赖

<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.badao.gmall</groupid>
  <artifactid>user-service-provider</artifactid>
  <version>0.0.1-snapshot</version>
  <dependencies>
  <dependency>
   <groupid>com.badao.gmall</groupid>
   <artifactid>gmall-interface</artifactid>
   <version>0.0.1-snapshot</version>
  </dependency>
  <!-- 引入dubbo -->
  <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo -->
  <dependency>
   <groupid>com.alibaba</groupid>
   <artifactid>dubbo</artifactid>
   <version>2.6.2</version>
  </dependency>
  <!-- 注册中心使用的是zookeeper，引入操作zookeeper的客户端端 -->
  <dependency>
   <groupid>org.apache.curator</groupid>
   <artifactid>curator-framework</artifactid>
   <version>2.12.0</version>
  </dependency>
 </dependencies>
</project>

 

然后新建接口实现类orderserviceimpl

package com.badao.gmall.service.impl;

import java.util.list;

import org.springframework.beans.factory.annotation.autowired;
import org.springframework.stereotype.service;

import com.badao.gmall.bean.useraddress;
import com.badao.gmall.service.orderservice;
import com.badao.gmall.service.userservice;

/**
 * 1、将服务提供者注册到注册中心（暴露服务）
 *   1）、导入dubbo依赖（2.6.2）\操作zookeeper的客户端(curator)
 *   2）、配置服务提供者
 * 
 * 2、让服务消费者去注册中心订阅服务提供者的服务地址
 * @author badao
 *
 */
@service
public class orderserviceimpl implements orderservice {

 @autowired
 userservice userservice;
 public list<useraddress> initorder(string userid) {
  // todo auto-generated method stub
  system.out.println("用户id："+userid);
  //1、查询用户的收货地址
  list<useraddress> addresslist = userservice.getuseraddresslist(userid);
  for (useraddress useraddress : addresslist) {
   system.out.println(useraddress.getuseraddress());
  }
  return addresslist;
 }
 
 

}

 

按照官方指示，同样新建服务消费者配置文件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://dubbo.apache.org/schema/dubbo"
 xmlns:context="http://www.springframework.org/schema/context"
 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.3.xsd
  http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
  http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 <context:component-scan base-package="com.badao.gmall.service.impl"></context:component-scan>


 <dubbo:application name="order-service-consumer"></dubbo:application>
 
 <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
 
 
 
 <!--声明需要调用的远程服务的接口；生成远程服务代理  -->
 <!-- 
  1）、精确优先 (方法级优先，接口级次之，全局配置再次之)
  2）、消费者设置优先(如果级别一样，则消费方优先，提供方次之)
 -->
 <dubbo:reference interface="com.badao.gmall.service.userservice" 
  id="userservice" timeout="5000" retries="3" version="*">
 </dubbo:reference>
  
</beans>

 

然后新建mainapplication，加载spring配置，并调用远程服务

package com.badao.gmall;

import java.io.ioexception;

import org.springframework.context.support.classpathxmlapplicationcontext;

import com.badao.gmall.service.orderservice;

public class mainapplication {
 
 @suppresswarnings("resource")
 public static void main(string[] args) throws ioexception {
  classpathxmlapplicationcontext applicationcontext = new classpathxmlapplicationcontext("consumer.xml");
  orderservice orderservice = applicationcontext.getbean(orderservice.class);
  orderservice.initorder("1");
  system.out.println("调用完成....");
  system.in.read();
 }

}

 

开始测试

参照官网快速搭建入门程序的指导：

搭建好服务提供者和服务消费者之后，参照上面博客搭建好zookeeper服务注册中心后，启动zookeeper服务端。

然后再参照博客搭建dubbo-admin管理控制台程序。

启动服务提供者的mainapplication使服务暴露。

此时刷新管理控制台，可见此时服务提供者已经暴露。

 

 

然后运行服务消费者的mainapplication,远程调用成功。

 

 

此时刷新管理控制台

 

 

服务提供者与服务消费者各一。

代码下载

关注公众号：

霸道的程序猿

回复：

dubbo入门代码


 

 


 


 

您可能感兴趣的文章:

如对本文有疑问， 点击进行留言回复！！

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网