本文版权归作者所有
,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接出处:https://blog.csdn.net/qq_3076499
,否则保留追究法律责任的权利。 如果文中有什么错误,欢迎指出。以免更多的人被误导。

如果觉得文章不错,对你有帮助,请作者喝杯咖啡,谢谢!如果对您有帮助
,请多多支持.多少都是您的心意与支持,一分也是爱,再次感谢!!!打开支付宝首页搜“556723462”领红包,领到大红包的小伙伴赶紧使用哦!感谢大家的支持!您的支持,我会继续分享更多的文章,欢迎关注!


微信端

支付宝端

支付宝红包端


 

如果实战入门一没搞懂,不妨可以再参考博主的实战入门文章二:
https://blog.csdn.net/qq_30764991/article/details/81221878
<https://blog.csdn.net/qq_30764991/article/details/81221878>

1. 什么是dubbo?

1.1. 简介


DUBBO是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,是阿里巴巴SOA服务化治理方案的核心框架,每天为2,000+个服务提供3,000,000,000+次访问量支持,并被广泛应用于阿里巴巴集团的各成员站点。


Dubbo是Alibaba开源的分布式服务框架,它最大的特点是按照分层的方式来架构,使用这种方式可以使各个层之间解耦合(或者最大限度地松耦合)。从服务模型的角度来看,Dubbo采用的是一种非常简单的模型,要么是提供方提供服务,要么是消费方消费服务,所以基于这一点可以抽象出服务提供方(Provider)和服务消费方(Consumer)两个角色。关于注册中心、协议支持、服务监控等内容。

 

2.远程过程调用协议

 

RPC(Remote Procedure Call)—远程过程调用
<https://baike.baidu.com/item/%E8%BF%9C%E7%A8%8B%E8%BF%87%E7%A8%8B%E8%B0%83%E7%94%A8>
,它是一种通过网络 <https://baike.baidu.com/item/%E7%BD%91%E7%BB%9C>
从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。RPC协议
<https://baike.baidu.com/item/RPC%E5%8D%8F%E8%AE%AE>假定某些传输协议
<https://baike.baidu.com/item/%E4%BC%A0%E8%BE%93%E5%8D%8F%E8%AE%AE>
的存在,如TCP或UDP,为通信程序之间携带信息数据。在OSI网络通信
<https://baike.baidu.com/item/%E7%BD%91%E7%BB%9C%E9%80%9A%E4%BF%A1>模型中,RPC跨越了传输层
<https://baike.baidu.com/item/%E4%BC%A0%E8%BE%93%E5%B1%82>和应用层
<https://baike.baidu.com/item/%E5%BA%94%E7%94%A8%E5%B1%82>。RPC使得开发包括网络分布式
<https://baike.baidu.com/item/%E5%88%86%E5%B8%83%E5%BC%8F>多程序在内的应用程序更加容易。


RPC采用客户机/服务器模式。请求程序就是一个客户机,而服务提供程序就是一个服务器。首先,客户机调用进程发送一个有进程参数的调用信息到服务进程,然后等待应答信息。在服务器端,进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达,服务器获得进程参数,计算结果,发送答复
信息 <https://baike.baidu.com/item/%E4%BF%A1%E6%81%AF>
,然后等待下一个调用信息,最后,客户端调用进程接收答复信息,获得进程结果,然后调用执行继续进行。

有多种 RPC模式和执行。最初由 Sun 公司提出。IETF ONC 宪章重新修订了 Sun 版本,使得 ONC RPC 协议成为 IETF
标准协议。现在使用最普遍的模式和执行是开放式软件基础的分布式计算环境
<https://baike.baidu.com/item/%E7%8E%AF%E5%A2%83>(DCE)。

3.Dubbo实战入门


在实战入门之前,请先了解zookeeper注册服务中心,然后再了解Dubbo与RPC远程调用协议,本文采用Dubbo与Zookeeper、Spring框架的整合。

主要是以下几个步骤: 

1. 安装Zookeeper,启动; 
2. 创建MAVEN项目,构建Dubbo+Zookeeper+Spring实现的简单Demo; 
3. 安装Dubbo-admin,实现监控。

3.1 Zookeeper介绍与安装

本Demo中的Dubbo注册中心采用的是Zookeeper。为什么采用Zookeeper呢?

Zookeeper是一个分布式的服务框架,是树型的目录服务的数据存储,能做到集群管理数据 ,这里能很好的作为Dubbo服务的注册中心。


Dubbo能与Zookeeper做到集群部署,当提供者出现断电等异常停机时,Zookeeper注册中心能自动删除提供者信息,当提供者重启时,能自动恢复注册数据,以及订阅请求


具体的安装方法在此不一一叙述,可参考我的另一篇Zookeeper博文: https://blog.csdn.net/qq_30764991/article/details/80188652

安装完成后,进入到bin目录,并且启动zkServer.cmd,这个脚本中会启动一个java进程: 
(注:需要先启动zookeeper后,后续dubbo demo代码运行才能使用zookeeper注册中心的功能) 



3.2 创建MAVEN项目

 

项目结构: 
主要分三大模块: 
dubboprovider-api : 存放公共接口; 
dubbo-consumer : 调用远程服务; 
dubbo-provider : 提供远程服务。具体结构如下:



3.3 向dubbo-provider的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.learn.dubbo</groupId>
  <artifactId>dubbo-provider</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>war</packaging>
  <description>这里是生产者,提供远程服务,注意这里是war包,需要提供容器</description>
<dependencies>
<!-- dubbo采用spring配置方式,所以需要导入spring容器依赖 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>4.1.3.RELEASE</version>
</dependency>
<!-- log4j日志依赖 -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.6.4</version>
</dependency>
<!-- dubbo版本依赖 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.3</version>
<exclusions>
<exclusion>
<!-- 排除传递spring依赖 -->
<artifactId>spring</artifactId>
<groupId>org.springframework</groupId>
</exclusion>
</exclusions>
</dependency>
<!--zookeeper的版本依赖  -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.3.3</version>
</dependency>
<!--zkclient注册中心版本  -->
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>

</dependencies>
<build>
<plugins>
<!-- tomcat7插件配置 -->
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<version>2.2</version>
<configuration>
<port>8181</port>
<path>/</path>
</configuration>
</plugin>
</plugins>
</build>
</project>

3.4 :log4j.properties的配置如下:

log4j.rootLogger=DEBUG,A1
log4j.appender.A1=org.apache.log4j.ConsoleAppender
log4j.appender.A1.layout=org.apache.log4j.PatternLayout
log4j.appender.A1.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss,SSS} [%t]
[%c]-[%p] %m%n

3.5:创建一个实体对象具体如下:

package com.dubbo.pojo;


//使用dubbo要求传输的对象必须实现序列化接口
public class User implements java.io.Serializable {
private static final long serialVersionUID = 5264854701181085862L;
private Long id;


private String username;


private String password;


private Integer age;


public Long getId() {
return id;
}


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


public String getUsername() {
return username;
}


public void setUsername(String username) {
this.username = username;
}


public String getPassword() {
return password;
}


public void setPassword(String password) {
this.password = password;
}


public Integer getAge() {
return age;
}


public void setAge(Integer age) {
this.age = age;
}

}

3.6:创建UserService(接口)提供查询服务,具体代码如下:

 

public interface UserService {
/**
* 查询所有用户数据
* @return
*/
public List<User> getAllUser();
}

3.7:创建UserServiceImpl实现类,具体代码如下:

package com.dubbo.service;
import java.util.ArrayList;
import java.util.List;


import com.dubbo.pojo.User;


public class UserServiceImpl implements UserService {
/*
* 这里是做的一个伪数据的查询,没有从数据库查询,
*/
public List<User> getAllUser() {
// 创建一个ArrayList集合
List<User> list = new ArrayList<User>();
// 循环创建用户
for (int i = 0; i < 10; i++) {
// 创建一个用户
User user = new User();
// 赋值年龄
user.setAge(10 + i);
// 赋值Id
user.setId(Long.valueOf(i + 1));
// 赋值密码
user.setPassword("123456");
// 赋值用户
user.setUsername("username_" + i);
// 添加用户
list.add(user);
}
// 返回这个集合
return list;
}
}

3.8:编写dubbo-service.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">
<!-- 提供方应用信息,用于计算依赖关系,dubbo-provider这个是项目名 -->
<dubbo:application name="dubbo-provider" />
<!-- 这里使用的注册中心是zookeeper -->
<dubbo:registry address="zookeeper://127.0.0.1:2181" client="zkclient"/>
<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol name="dubbo" port="20880" />
<!-- 将该接口暴露到dubbo中 -->
<dubbo:service interface="com.dubbo.service.UserService"
ref="userServiceImpl" />
<!--暴露几个就写相应的接口以及对应的实现类  -->
<!-- <dubbo:service interface="com.dubbo.service.UserService"
ref="userServiceImpl" /> -->
<!-- 将具体的实现类加入到Spring容器中 -->
<bean id="userServiceImpl" class="com.dubbo.service.UserServiceImpl" />
</beans>

3.9:编写web.xml配置,具体代码如下:

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://java.sun.com/xml/ns/javaee"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5">
  <display-name>dubbo-provider</display-name>
<!-- 加载dubbo的配置文件 -->
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:dubbo/dubbo-*.xml</param-value>
</context-param>
<!--Spring的ApplicationContext 载入 -->
<listener>

<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
  
</web-app>

3.10:启动tomcat7服务。那么到此,这个生产服务的就弄好了,接下是写消费者的配置了。


4.1:向dubbo-consumer项目中,导入相应的依赖,与dubbo-provider的依赖一样,这里不粘贴代码了。然后也是一样配置log4j.properties配置,这里也是一样。

4.2,把dubbo-provider的实体对象user与userservice接口粘贴到dubbo-consumer项目中。

4.3.dubbo-consumer.xml:的配置如下:

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
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-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<!-- 提供方应用信息,用于计算依赖关系 -->
<dubbo:application name="dubbo-consumer" />


<!-- 这里使用的注册中心是zookeeper -->
<dubbo:registry address="zookeeper://127.0.0.1:2181" client="zkclient"/>

<!-- 从注册中心中查找服务 -->
<dubbo:reference id="userService" interface="com.dubbo.service.UserService"/>
 
</beans>

4.4,测试userService,具体代码如下:

package com.dubbo.service;
import java.util.List;
import org.junit.Before;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.dubbo.pojo.User;
public class UserServiceTest {
private UserService userService;
@Before
public void setUp() throws Exception {
// 获取spring的容器
ApplicationContext applicationContext = new ClassPathXmlApplicationContext(
"classpath:dubbo/*.xml");
// 从容器中得到对应 的数据
this.userService = applicationContext.getBean(UserService.class);
}
@Test
public void testgetAll() {
List<User> users = this.userService.getAllUser();
for (User user : users) {
System.out.println(user);
}
}
}

注意启动测试的时候需要先启动dubbo-provider项目。

如果实战入门一没搞懂,不妨可以再参考博主的实战入门文章二:
https://blog.csdn.net/qq_30764991/article/details/81221878
<https://blog.csdn.net/qq_30764991/article/details/81221878>

友情链接
ioDraw流程图
API参考文档
OK工具箱
云服务器优惠
阿里云优惠券
腾讯云优惠券
华为云优惠券
站点信息
问题反馈
邮箱:ixiaoyang8@qq.com
QQ群:637538335
关注微信