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

　　二、dubbo的基本原理（这个是用于dubbo的工作原理比较重要的一个环节）

　　

　　这是图中的几个节点的意义

  • Provider：暴露服务的服务提供方，或者直白点说就是服务生产者
  • Consumer：调用远程服务的服务消费方，也就是服务消费者
  • Registry：服务注册与发现的注册中心
  • Monitor：统计服务的调用次数和调用时间的监控中心
  • Container：服务（生产者）运行容器

 　　具体的调用步骤

  • 0：服务容器负责启动、加载、运行服务提供者（生产者）
  • 1：服务提供者（生产者）在启动时，向注册中心注册自己提供的服务
  • 2：服务消费者在启动时，向注册中心订阅自己所需的服务
  • 3：注册中心返回服务提供者地址列表给消费者，如果有变更，注册中细腻将基于长连接推送变更数据给消费者
  • 4：服务消费者从服务生产者地址列表中，基于软负载均衡算法，选择一台提供者（生产者）进行调用，如果调用失败，再选另一台调用
  • 5：服务消费者和提供者（生产者），在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心

 　　三、下面我会通过一个例子来说明具体的实现过程，以及配置

　　1）说明：dubbo是用来做分布式工程而提出来的一个框架。相对于原来的单体工程来说，dubbo的灵活性，以及调整的方式都更加灵活。dubbo的方式是将service一下的单独提出来做成一个项目，也就是我们提到的SOA模式，面向服务的框架。在设计中，web端只看得到对应的接口，而不需要知道实现过程。具体的实现过程在另外一个项目实现。中间的通行通过zookeeper来实现传输。

　　2）我这里写了一个简单的例子来说明这个服务提供的过程，和相对应用独立使用的过程。（目录）

　　

　　1、do-parent用来加载公用的jar包，没有实际代码

　　a、pom. 

<?  version="1.0" encoding="UTF-8"?><project  ns="http://maven.apache.org/POM/4.0.0"          ns:xsi="http://www.w3.org/2001/ Schema-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.troy</groupId>    <artifactId>do-parent</artifactId>    <version>1.0-SNAPSHOT</version>    <modules>        <module>do-interface</module>        <module>do-service</module>        <module>do-web</module>    </modules>    <parent>        <groupId>org.spring work.boot</groupId>        <artifactId>spring-boot-starter-parent</artifactId>        <version>1.5.9.RELEASE</version>    </parent>    <dependencies>        <dependency>            <groupId>org.spring work.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>            <version>1.5.9.RELEASE</version>        </dependency>        <dependency>            <groupId>org.spring work.boot</groupId>            <artifactId>spring-boot-starter-data-jpa</artifactId>            <version>1.5.9.RELEASE</version>        </dependency>        <dependency>            <groupId>com.alibaba</groupId>            <artifactId>dubbo</artifactId>            <version>2.5.7</version>        </dependency>        <dependency>            <groupId>mysql</groupId>            <artifactId>mysql-connector-java</artifactId>            <version>5.1.9</version>        </dependency>        <dependency>            <groupId>org.apache.zookeeper</groupId>            <artifactId>zookeeper</artifactId>            <version>3.4.9</version>        </dependency>        <dependency>            <groupId>com.101tec</groupId>            <artifactId>zkclient</artifactId>            <version>0.10</version>        </dependency>    </dependencies></project>

　　2、do-interface用来提供暴露的接口，提供给do-web和do-service。共同的调用方法

　　a、目录结构

　　

　　b、User共同使用的实体类

package com.troy.domain;import javax.persistence.*;import java.io.Serializable;@Entity@Table(name = "USER")public class User implements Serializable{    @Id    @GeneratedValue(strategy = GenerationType.AUTO)    private Long id;    private String name;    private Integer age;    public Long getId() {        return id;    }    public void setId(Long id) {        this.id = id;    }    public String getName() {        return name;    }    public void setName(String name) {        this.name = name;    }    public Integer getAge() {        return age;    }    public void setAge(Integer age) {        this.age = age;    }}

　　c、IUserService只用来提供接口，不做任何实现

package com.troy.service;import com.troy.domain.User;import java.util.List;public interface IUserService {    public List<User> findAll();}

　　d、application-dao.yml的配置用来连接数据库，这个因为我用的是一套数据库，所以公用的数据库配置

spring:  datasource:    driver-class-name: com.mysql.jdbc.Driver    url: jdbc:mysql://localhost:3306/model?useUnicode=true&amp;characterEncoding=UTF-8    password: root    username: root

　　3、do-service用来提供具体的接口实现

　　a、目录结构

　　

 

　　b、repository用来，设置基本的数据库访问层

package com.troy.repository;import org.spring work.data.jpa.repository.JpaSpecificationExecutor;import org.spring work.data.repository.NoRepositoryBean;import org.spring work.data.repository.PagingAndSortingRepository;import java.io.Serializable;@NoRepositoryBeanpublic interface  Repository<T,I extends Serializable> extends PagingAndSortingRepository<T,I>,JpaSpecificationExecutor<T> {}
package com.troy.repository;import com.troy.domain.User;public interface UserRepository extends  Repository<User,Long> {}

　　c、service用来写具体的实现过程

package com.troy.service;import com.troy.domain.User;import com.troy.repository.UserRepository;import org.spring work.beans.factory.annotation.Autowired;import org.spring work.stereotype.Service;import javax.transaction.Transactional;import java.util.ArrayList;import java.util.Iterator;import java.util.List;@Service(value = "userService")@Transactionalpublic class UserServiceImpl implements IUserService {    @Autowired    private UserRepository userRepository;    public List<User> findAll() {        List<User> users = new ArrayList<User>();        Iterator<User> iterator = this.userRepository.findAll().iterator();        while (iterator.hasNext()) {            users.add(iterator.next());        }        return users;    }}

　　d、config下面是进行相关的配置，对于服务提供者

package com.troy.config;import org.spring work.context.annotation.Configuration;import org.spring work.context.annotation.ImportResource;@Configuration@ImportResource("classpath:dubbo/*. ")public class DubboProvider {}

　　dubbo-provider. 的具体配置

<?  version="1.0" encoding="UTF-8"?><beans  ns="http://www.spring work.org/schema/beans"     ns:xsi="http://www.w3.org/2001/ Schema-instance"  ns:dubbo="http://code.alibabatech.com/schema/dubbo"    xsi:schemaLocation="http://www.spring work.org/schema/beans              http://www.spring work.org/schema/beans/spring-beans.xsd              http://code.alibabatech.com/schema/dubbo              http://code.alibabatech.com/schema/dubbo/dubbo.xsd">    <!-- 提供方应用信息，用于计算依赖关系 -->    <dubbo:application name="dubbo-provider" />    <!-- 使用zookeeper注册中心暴露服务地址 -->    <dubbo:registry protocol="zookeeper" address="192.168.5.10:2181" />    <!-- 用dubbo协议在20880端口暴露服务 -->    <dubbo:protocol name="dubbo" port="20880" />            <!-- 用户服务接口 -->    <dubbo:service interface="com.troy.service.IUserService" ref="userService" /></beans>

　　e、具体的启动过程

package com.troy;import org.spring work.boot.SpringApplication;import org.spring work.boot.autoconfigure.SpringBootApplication;import java.util.HashMap;import java.util.Map;@SpringBootApplicationpublic class ApplicationService {    public static void main(String[] args) {        SpringApplication application = new SpringApplication(ApplicationService.class);        Map<String, > map = new HashMap<String,  >();        //这里的目的是加入相关配置        map.put("spring.profiles.default","service,dao");        application.setDefaultProperties(map);        application.run(args);    }}

　　4、do-web的目的是用来获取数据，提供数据，当然也可以用来具体页面的呈现

　　a、目录接口

　　

　　b、web，具体的数据提供者

package com.troy.web;import com.troy.service.IUserService;import org.spring work.beans.factory.annotation.Autowired;import org.spring work.context.annotation.Scope;import org.spring work.web.bind.annotation.RequestMapping;import org.spring work.web.bind.annotation.RequestMethod;import org.spring work.web.bind.annotation.RestController;@RestController@RequestMapping("/api/user")@Scope("prototype")public class UserResource {    @Autowired    private IUserService userService;    @RequestMapping(value = "/findAll")    public   findAll() {        return this.userService.findAll();    }}

　　c、config消费者配置

package com.troy.config;import org.spring work.context.annotation.Configuration;import org.spring work.context.annotation.ImportResource;@Configuration@ImportResource("classpath:dubbo/*. ")public class DubboConsumer {}

　　dubbo-consumer. 

<?  version="1.0" encoding="UTF-8"?><beans  ns="http://www.spring work.org/schema/beans"  ns:xsi="http://www.w3.org/2001/ Schema-instance"  ns:dubbo="http://code.alibabatech.com/schema/dubbo"    xsi:schemaLocation="http://www.spring work.org/schema/beans          http://www.spring work.org/schema/beans/spring-beans.xsd          http://code.alibabatech.com/schema/dubbo          http://code.alibabatech.com/schema/dubbo/dubbo.xsd">    <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->    <dubbo:application name="dubbo-consumer" />    <!-- 使用zookeeper注册中心暴露服务地址 -->    <!-- 注册中心地址 -->    <dubbo:registry protocol="zookeeper" address="192.168.5.10:2181" />        <!-- 用户服务接口 -->    <dubbo:reference interface="com.troy.service.IUserService" id="userService" check="false" /></beans>

　　d、启动配置

package com.troy;import org.spring work.boot.SpringApplication;import org.spring work.boot.autoconfigure.SpringBootApplication;import java.util.HashMap;import java.util.Map;@SpringBootApplicationpublic class Application {    public static void main(String[] args) {        SpringApplication application = new SpringApplication(Application.class);        Map<String, > map = new HashMap<String,  >();        map.put("spring.profiles.default","web,dao");        application.setDefaultProperties(map);        application.run(args);    }}

　　四、中间需要用到zookeeper，来做注册中心。

　　zookeeper的安装部署：http://www.cnblogs.com/ll409546297/p/7526953.html

　　zookeeper的展示界面：http://www.cnblogs.com/ll409546297/p/7814564.html

 　　五、dubbo的方式，目前各大网站上面应用的非常普遍。当然我这边只是做的一个例子用来，了解dubbo的分布式实现过程，和具体的应用方式。

　　代码层面存在不理想的地方，请见谅！！！

　　源码下载：https://pan.baidu.com/s/1c1SUnFa

继续阅读与本文标签相同的文章

None
最新文章 最热文章
收藏 打印

特别推荐 2026年05月26日 星期二

精彩发现

热门标签

阻止表单提交 窗口 关闭浏览器 清除 CDATA css文件 光标位置 坐标 javascrpt !important 超链接 数字

相关文章

1
ssh服务使用介绍二
281人阅读
2
ssh服务介绍
849人阅读
3
为公司内部搭建CA
1720人阅读