一、前言
最近接到公司的项目, 其中技术用到了springboot、 dubbo、 zookeeper、 activiti、 kafka等, 有些东西是比较熟悉, 有些只是稍微看过, 还不是很懂; 个人认为做一个项目就要去了解该项目用的所有技术, 知己知彼方能百战不殆嘛; 后面我也会陆续更新相关技术栈的搭建~然后慢慢的深入的去了解;
可以先下载demo看一看~~~~
Dubbo_Github_Demo
二、Dubbo
Dubbo官网
上面有详细的Dubb文档, 但是在创建Dubbo项目时让我一头雾水, 网上也找了相关的视频看, 也是很懵逼; 这里官网给的文档, 跟alibaba的github上面的案例又不一样; 下面我讲写一个我自己搭成功的案例
1. Dubbo是什么
Dubbo是阿里巴巴公司开源的一个高性能优秀的服务框架，使得应用可通过高性能的 RPC 实现服务的输出和输入功能，可以和 Spring框架无缝集成。
Dubbo是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。
Dubbo和SpringCloud一样, 是一个分布式框架, 如果对SpringCloud有兴趣的可以:
1. SrpingCloud之Eureka--服务治理
2. SrpingCloud使用过Eureka怎么进行服务间相互访问--Feign
3. SrpingCloud调用方法异常怎么办--Hystrix使用讲解
4. SrpingCloud服务之间的负载均衡
2. Dubbo的架构
执行流程：
- Provider：服务的提供者，负责对外提供服务，提供者在启动的时候，需要向Registry注册自己能够提供
的服务- Consumer：服务的消费者，消费者在启动的时候，需要向Registry订阅自己需要的服务
- Registry：注册中心，授受注册和订阅，会异步的通知订阅者，向消费者提供服务列表
- 当消费者需要执行远程过程调用时，会从Registry获取到服务地址列表（基于负载均衡算法）进行调用，
如果调用失败会重新选择新的提供者再次调用- Monitor：监控中心，统计服务的调用次数和调用时间，服务消费者和提供者会在内存中累计调用次数和
调用时间，定时每分钟向监控中心发送一次统计数据
3. Dubbo创建三部曲
3.1 创建一个接口
这里说接口, 我个人认为可以将一些公用的类放在一个工程里面, 通过jar包形式使项目之间相互引用, 这里我只放了实体类, 定义的接口(service接口)
使用到的jar:
<!-- 简化开发的工具, 这里只用到在实体类上@Data注解,
减少get/set方法生成, 使用时在ide添加插件, 不会自行百度 -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.2</version>
</dependency>
创建的类:
这里强调下,~返回对象一定要实现Serializable接口, 不然会序列化失败;
package com.example.pojo;
import lombok.Data;
import java.io.Serializable;
/**
* 用户
*/
@Data
//这里注意下, 一定要实现Serializable接口~, 不然消费者调用返回json时候会序列化失败
public class User implements Serializable{
private Integer id;
private String name;
private Integer age;
}
定义的接口:
package com.example.service;
import com.example.pojo.User;
/**
* 该地方只定义接口, 一般为公用接口
* 可以定义许多接口; 这里为了演示, 只定义一个
*/
public interface UserService {
User getUserById(int id);
}
说明, 方便演示这里直接用的jar的方式被生产者和消费者应用, 实际项目中是打成jar包的形式给生产者/消费者使用;
3.2 创建生产者
创建一个springboot项目; 然后编写接口的实现类
使用到的jar:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.38</version>
</dependency>
<!--接口, 3.1我们定义的接口, 这里进行引用-->
<dependency>
<groupId>com.example</groupId>
<artifactId>dubbo-interface</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<!-- dubbo starter 这里已经集成了zookeeper的客户端jar -->
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.2.0</version>
</dependency>
<!--myabtis plus-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.0.6</version>
</dependency>
<!-- 使用阿里的数据库数据源 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.12</version>
</dependency>
编写的类:
- myabtis的配置类, 这里不贴了, 不是关键代码; 需要去看github上的demo
- 数据从数据库里面拿的, dao + mapper这里也不贴了, 就是简单的根据用户id查询用户数据
重点, 实现类
@Service 注解 import com.alibaba.dubbo.config.annotation.Service;
package com.example.dubboproducer.impl;
import com.alibaba.dubbo.config.annotation.Service;
import com.example.dubboproducer.dao.UserDao;
import com.example.pojo.User;
import com.example.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Service //这里是dubbo的注解, 将接口暴露在外, 可以供调用, 这里就是放在了注册中心
//@org.springframework.stereotype.Service spring自己的注解, 为了区分, 使用了@Component
@Component //让spring扫描该类, 用spring的 @Service也行
public class UserServiceImpl implements UserService {
@Autowired
private UserDao userDao;
@Override
public User getUserById(int id) {
return userDao.selectUserById(id);
}
}
yml配置:
spring:
datasource:
url: jdbc:mysql://localhost:3306/dubbo?useUnicode=true&characterEncoding=utf-8
username: root
password: root
mybatis-plus:
type-aliases-package: com.example.pojo
mapper-locations: classpath:mapper/*.xml
global-config:
db-config:
id-type: auto
#*****************分割线, 上面我就不解释了, 下面是dubbo的配置************************
dubbo:
application:
name: dubbo-producer #dubbo的注册的服务名, 唯一性
registry:
address: zookeeper://127.0.0.1:2181 #注册zookeeper的地址
启动Dubbo配置:
@EnableDubbo 注解
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
package com.example.dubboproducer;
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@EnableDubbo //启动dubbo的配置
public class DubboProducerApplication {
public static void main(String[] args) {
SpringApplication.run(DubboProducerApplication.class, args);
}
}
3.3 创建消费者
创建的方法和生产者类似, 这里为了让大家更好的看明白使用;
使用的jar:
这里直接调用生产者的服务, 没有其他的交互, 这里就没有引用数据库的工具
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- dubbo -->
<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.2.0</version>
</dependency>
<!-- 使用3.1的创建的接口 -->
<dependency>
<groupId>com.example</groupId>
<artifactId>dubbo-interface</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
使用的类:
创建controller, 完成调用消费者;
@Reference 注解 import com.alibaba.dubbo.config.annotation.Reference;
package com.example.dubboconsumer.controller;
import com.alibaba.dubbo.config.annotation.Reference;
import com.example.service.UserService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/user")
public class UserController {
@Reference //将生产者注册到Dubbo映射到该对象上, 这里完成了服务之间的调用
private UserService userService;
@RequestMapping("/getUserById")
public Object getUserById (int id){
return userService.getUserById(id);
}
}
yml配置:
dubbo:
application:
name: dubbo-consumer
registry:
address: zookeeper://127.0.0.1:2181
server:
port: 8081 #应为我这里是将服务起在一台电脑, 和生产者的tomcat端口区分以免冲突
如果消费者也有服务要注册到Dubbo中, 也在启动类上添加注解@EnbaleDubbo
3.4 测试
- 启动生产者
- 启动消费者
两者都没有报错, 并看到tomcat端口时, 说明启动成功; -
测试接口
测试成功.jpg - 查看zookeeper中注册的服务
zookeeper中注册的服务.jpg
UserService 就是我们注册在zookeeper中的服务
