springboot 多模块 -- 将web拆分出去 - 流动计算架构 - Java

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

前言:

之前将各层都拆分出去, 作为一个独立的可替换的子模块. 感觉比以前确实是灵活了一些.

不管是电商项目, 还是现在公司做的项目, 其中, 有很多的业务逻辑, 都是一样的, 但是由于不在一个系统中, 大家需要进行重复的工作. 有的拷贝还好, 但是有的, 没法直接拷贝. 相当的蛋疼. 能不能, 将业务逻辑独立出去, 供所有的展示层调用呢?

是不是可以使用前一篇介绍的 dubbo 呢?

框架改造:

前一篇, 通过多模块, 将各层拆分出去, 各自变成了一个独立的项目. 这里, 先将之前的稍微修改了下, 主要是改了项目名称, 加了一个common项目, 放一些共用的东西.

common我也是用 springboot 建的, 只不过将入口那里注释掉了. 这里, 除了web有入口程序, 其他的入口全都注释掉了.

改造后的目录结构:

这里要注意开启service中的入口程序, 创建application.yml文件, 将之前在web中, 对mybatis的配置部分, 全部迁移到service中, 包括 MybatisConfig 和 MybatisMapperScannerConfig.

迁移哦, 不是复制. web端不需要这些东西了.

具体的改造过程, 就不贴了, 代码我会上传到码云中. 地址: https://gitee.com/elvinle/bookshop/tree/master/bookshop

集成dubbo zookeeper:

1. 业务层改造 -- 服务端

pom.xml 中加入:

<dependency>
<groupId>com.gitee.reger</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<exclusions>
<exclusion>
<groupId>org.jboss.netty</groupId>
<artifactId>netty</artifactId>
</exclusion>
</exclusions>
</dependency>

application.yml:

spring:
dubbo:
application: bookshop_provider
registry:
address: 192.168.153.129
protocol: zookeeper
port: 2181
protocol:
name: dubbo
port: 20880
base-package: cn.elvinle.manager.simpl

application : 名称自己随便取一个都可以, 不重复就好.

address : 前面zookeeper部署的电脑ip.

port: zookeeper服务的端口号

registry.protocol : 注册协议, zookeeper注册中心, 默认2181端口

dubbo.protocol : 服务协议, 使用 dubbo

dubbo.port : 服务端口, 默认20880

timeout : 调用超时, 默认为1000ms.

base-package : 客户端被扫描的包

这里使用的是单机部署, 没有使用zookeeper集群. 后面有机会的话, 会使用到.

代码改造:

package cn.elvinle.manager.simpl;import cn.elvinle.manager.dao.mapper.UserMapper;
import cn.elvinle.manager.pojo.User;
import cn.elvinle.manager.service.UserService;
import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.beans.factory.annotation.Autowired;import java.util.List;@Service
public class UserSImpl implements UserService { @Autowired
private UserMapper userMapper; @Override
public List<User> getAll() { List<User> list = userMapper.getAll(); System.out.println("服务端读取到数据：" + list); return list;
}
}

这里貌似与之前的没什么不同, 但是, 这里的Service 注解, 不是之前的那个了, 而是 com.alibaba.dubbo.config.annotation.Service

2. web 集成 -- 客户端

pom.xml文件加入引用:

application.yml

spring:
dubbo:
application: web_consumer
registry:
address: 192.168.153.129
protocol: zookeeper
port: 2181
base-package: cn.elvinle.manager.web.controller
consumer:
timeout: 10000

代码改造:

package cn.elvinle.web.controller;import cn.elvinle.manager.pojo.User;
import cn.elvinle.manager.service.UserService;
import com.alibaba.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;@RestController
@RequestMapping("user")
public class UserController { @Reference
private UserService userService; @RequestMapping("index")
public List<User> index(){ List<User> all = userService.getAll(); System.out.println("客户端读取到数据: " + all); return all;
}
}

这里, 可以看到, 不再是使用Autowire了, 而是使用Reference注解, 是dubbo里面的.

3. 注意:

这里有个需要注意的地方, 就是传输的类, 必须实现 Serializable 接口, 表示支持序列化, 否则会报错的.