SpringCloud（Finchley.RELEASE）+SpringBoot（2.0.7）项目骨架，eureka+config+bus+feign+ribbon+hystrix+zuul等组件支持，MyBatis+Redis+MongoDB+RabbitMQ+Elasticsearch等集群配置，LCN（5.0.2.RELEASE）分布式事务框架，支持Docker部署。
作者QQ：709931138 作者邮箱：[email protected]
具体业务代码参见：https://github.com/D2C-Cai/shop-mall 支持平滑分布式改造
骨架项目的精髓：框架流行，版本要新，配置清晰，代码简洁，案例完整。依赖最小化，不拖泥带水，不自以为是。
此项目适用于有一定开发基础的开发者使用，项目内使用的框架和中间件都是市面上非常流行的，如何搭建环境的教程不作详细介绍，请开发者自行搭建必要的环境。
作者开发电脑局域网IP：192.168.5.20，服务器的局域网IP：192.168.0.146，要保证网络畅通，防火墙配置正确。
这里只给出几点建议：Linux服务器作者选用CentOS版本7，JDK选用1.8，MySql数据库5.6建议直接安装在系统上。一些中间件不论单机或集群请务必安装启动：Redis, Mongodb, Rabbitmq, Elasticsearch。
还有一个tx-manager，项目里带了txlcn-tm-5.0.2.RELEASE.jar，注意解压找到application.properties后修改配置，需要redis和mysql，这个是LCN分布式事务的管理服务端，LCN5.0以上版本是普通的SpringBoot项目，去官网下载源码，mvn打包启动就行。
下面会给出Docker容器中快捷安装的方案，注意容器时区，以及目录的映射，命令只是建议，不要照抄！
| 名称 | 介绍 | 说明 |
|---|---|---|
| admin-server |
远程监控管理服务 | 监控基于SpringBoot的应用，简洁的可视化UI |
| config-server |
远程配置管理服务 | 远程配置文件地址：https://github.com/D2C-Cai/mall-config |
| erureka-server |
cloud微服务注册中心 | 基于REST的定位服务，以实现云端中间层服务发现和故障转移 |
| mall-portal |
mall商城入口服务 | 用于演示 feign+ribbon+hystrix+zuul 等组件基本的使用和配置 |
| service-member |
mall会员微服务(仅演示) | SpringBoot+MybatisPlus框架的业务模块微服务，可随意扩展重建， 附带feign+config+bus等组件以及LCN分布式事务参与端的演示， 整合Redis+MongoDB+RabbitMQ+Elasticsearch中间件的基本使用 |
| service-order |
mall订单微服务(仅演示) | SpringBoot+MybatisPlus框架的业务模块微服务，可随意扩展重建， 附带feign+config+bus等组件以及LCN分布式事务发起端的演示， 整合Redis+MongoDB+RabbitMQ+Elasticsearch中间件的基本使用 |
| service-product |
mall商品微服务(仅演示) | SpringBoot+MybatisPlus框架的业务模块微服务，可随意扩展重建， 附带feign+config+bus等组件以及LCN分布式事务参与端的演示， 整合Redis+MongoDB+RabbitMQ+Elasticsearch中间件的基本使用 |
| 名称 | 版本 | 说明 |
|---|---|---|
| SpringCloud | Finchley.RELEASE | 与SpringBoot版本对应 |
| SpringBoot | 2.0.7 | 与SpringCloud版本对应 |
| MybatisPlus | 3.0.7.1 | Mybatis升级版，官网：https://mp.baomidou.com 用法详见：https://github.com/D2C-Cai/shop-mall |
| TX-LCN | 5.0.2.RELEASE | 高性能的分布式事务解决方案，官网：http://www.txlcn.org/zh-cn |
| 名称 | 版本 |
|---|---|
| MySql | 5.6 |
| Redis | 3.2 |
| Mongodb | 3.2 |
| Elasticsearch | 5.6.8 |
| Elasticsearch-ik | 5.6.x |
| Elasticsearch-head | 5 |
| Rabbitmq | 3.7.8 |
<dependency>
<groupId>com.codingapi.txlcn</groupId>
<artifactId>txlcn-tc</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<dependency>
<groupId>com.codingapi.txlcn</groupId>
<artifactId>txlcn-txmsg-netty</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
# tx-lcn
tx-lcn:
client:
manager-address: 192.168.0.146:8070
resource-order: 0
logger:
enabled: false
message:
netty:
wait-time: 5000
springcloud:
loadbalance:
enabled: true
解释： 这里注意我们用的是 5.0.2.RELEASE 版本
@Configuration
@EnableDiscoveryClient
@EnableDistributedTransaction
public class TransactionConfig {
}
解释： 每个需要的客户端，都加上这两个标签的配置@EnableDiscoveryClient，@EnableDistributedTransaction
@FeignClient(name = "service-member", fallback = MemberClientFallback.class)
public interface MemberClient {
@GetMapping("/api/user/update/{id}")
int updatePasswdById(@PathVariable(name = "id") Long id, @RequestParam(value = "password") String password);
}
@FeignClient(name = "service-product", fallback = ProductClientFallback.class)
public interface ProductClient {
@GetMapping("/api/product/update/{id}")
int updatePriceById(@PathVariable(name = "id") Long id, @RequestParam(value = "price") BigDecimal price);
}
解释： 这里是一个service-order通过FeignClient远程调用service-member和service-product的例子
@Override
@LcnTransaction
@Transactional
public int doSomeThing(String sn, Long productId, Long memberId) {
int rs1 = orderMapper.updateAmountBySn(sn, new BigDecimal((int) (Math.random() * 100 + 1)));
int rs2 = memberClient.updatePasswdById(memberId, String.valueOf((int) (Math.random() * 100 + 1)));
int rs3 = productClient.updatePriceById(productId, new BigDecimal((int) (Math.random() * 100 + 1)));
//return rs1 + rs2 + rs3;
throw new RuntimeException("doSomeThing更新失败");
}
解释： 这里使用LCN模式，其他模式也类似，发起端@LcnTransaction，propagation默认是REQUIRED
@Override
@LcnTransaction(propagation = DTXPropagation.SUPPORTS)
@Transactional
public int updatePasswdById(Long id, String password) {
return userMapper.updatePasswdById(id, password);
}
@Override
@LcnTransaction(propagation = DTXPropagation.SUPPORTS)
@Transactional
public int updatePriceById(Long id, BigDecimal price) {
return productMapper.updatePriceById(id, price);
}
解释：
这里使用LCN模式，其他模式也类似，参与端@LcnTransaction(propagation = DTXPropagation.SUPPORTS)
propagation有两种传播属性 REQUIRED（当前没有分布式事务，就创建。当前有分布式事务，就加入），SUPPORTS（当前没有分布式事务，非分布式事务运行。当前有分布式事务，就加入）
spring.application.name=tx-manager
server.port=7970
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://192.168.0.146:3306/tx-manager?characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=123456
mybatis.configuration.map-underscore-to-camel-case=true
mybatis.configuration.use-generated-keys=true
spring.redis.host=192.168.0.146
spring.redis.port=6379
spring.redis.password=
tx-lcn.manager.host=192.168.0.146
tx-lcn.manager.port=8070
tx-lcn.manager.admin-key=codingapi
# 心跳检测时间(ms)
tx-lcn.manager.heart-time=15000
# 分布式事务执行总时间(ms)
tx-lcn.manager.dtx-time=30000
# 参数延迟删除时间(ms)
tx-lcn.message.netty.attr-delay-time=10000
# 事务处理并发等级. 默认为机器逻辑核心数5倍
#tx-lcn.manager.concurrent-level=128
# 开启日志
#tx-lcn.logger.enabled=true
#logging.level.com.codingapi=debug
解释： 注意服务端需要建立的几个数据库的表，官方代码里有sql脚本，这里不做展示
LCN模式，多个同名微服务部署环境下，在事务通知时，存在随机通知其中一个微服务的BUG，而不是定位到真正参与事务的那个微服务。解决方案就是通过ip+port作为标识来区分，需要修改源码如下：
txlcn-tc模块下，增加如下代码，意为扩展ModId的生成方式：
package com.codingapi.txlcn.tc.support;
import com.codingapi.txlcn.common.util.id.ModIdProvider;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import java.net.InetAddress;
import java.net.UnknownHostException;
@Component
public class MyModIdProvider implements ModIdProvider {
@Value("${server.port}")
private int serverPort;
public String getServerID() {
InetAddress address = null;
try {
address = InetAddress.getLocalHost();
} catch (UnknownHostException e) {
e.printStackTrace();
}
return "http://" + address.getHostAddress() + ":" + this.serverPort;
}
@Override
public String modId() {
return getServerID();
}
}
txlcn-txmsg-netty模块下，找到这个类com.codingapi.txlcn.txmsg.netty.bean.SocketManager
/**
* 获取模块名称
*
* @param remoteKey 远程唯一标识
* @return 模块名称
*/
public String getModuleName(String remoteKey) {
AppInfo appInfo = appNames.get(remoteKey);
return appInfo == null ? null : appInfo.getAppName(); // 原来的getAppName()
}
/**
* 获取模块名称
*
* @param remoteKey 远程唯一标识
* @return 模块名称
*/
public String getModuleName(String remoteKey) {
AppInfo appInfo = appNames.get(remoteKey);
return appInfo == null ? null : appInfo.getLabelName(); // 修改为getLabelName()
}
docker pull redis:3.2
docker run -p 6379:6379 --name redis -v /etc/localtime:/etc/localtime:ro -v /mnt/docker/redis/data:/data -d redis:3.2 redis-server --appendonly yes
docker pull mongo:3.2
docker run -p 27017:27017 --name mongodb -v /etc/localtime:/etc/localtime:ro -v /mnt/docker/mongodb/db:/data/db -d mongo:3.2
docker pull rabbitmq:management
docker run -p 5672:5672 -p 15672:15672 --name rabbitmq -v /etc/localtime:/etc/localtime:ro -d rabbitmq:management
https://dl.bintray.com/rabbitmq/community-plugins/3.7.x/rabbitmq_delayed_message_exchange 去这里下载一个版本3.7.x版本的插件，解压到/mnt/docker/rabbitmq，如下方式安装，最后重启容器即可
docker cp /mnt/docker/rabbitmq/rabbitmq_delayed_message_exchange-20171201-3.7.x.ez (容器ID):/plugins
docker exec -it (容器ID) /bin/bash
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
rabbitmq-plugins list
exit
docker restart (容器ID)
vi /etc/sysctl.conf
#文件中加入一行
vm.max_map_count=655360
sysctl -p
docker pull elasticsearch:5.6.8
http.host: 0.0.0.0
#集群名称 所有节点要相同
cluster.name: "d2cmall-es"
#本节点名称
node.name: master
#作为master节点
node.master: true
#是否存储数据
node.data: true
# head插件设置
http.cors.enabled: true
http.cors.allow-origin: "*"
#设置可以访问的ip 这里全部设置通过
network.bind_host: 0.0.0.0
#设置节点 访问的地址 设置master所在机器的ip
network.publish_host: 192.168.0.146
docker run -p 9200:9200 -p 9300:9300 --name elasticsearch -v /etc/localtime:/etc/localtime:ro -v /mnt/docker/elasticsearch/config/elasticsearch.yml:/usr/share/elasticsearch/config/elasticsearch.yml -v /mnt/docker/elasticsearch/data:/usr/share/elasticsearch/data -v /mnt/docker/elasticsearch/plugins:/usr/share/elasticsearch/plugins -v /mnt/docker/elasticsearch/logs:/usr/share/elasticsearch/logs -d elasticsearch:5.6.8
curl -XPUT http://192.168.0.146:9200/index
https://github.com/medcl/elasticsearch-analysis-ik/releases 去这里下载一个版本5.6.x版本的插件，解压到/mnt/docker/elasticsearch/plugins下，最后重启容器即可
docker restart (容器ID)
curl 'http://192.168.0.146:9200/index/_analyze?analyzer=ik_max_word&pretty=true' -d '{"text":"我们是大数据开发技术人员"}'
docker pull mobz/elasticsearch-head:5
docker run -p 9100:9100 --name elasticsearch-head -v /etc/localtime:/etc/localtime:ro -d mobz/elasticsearch-head:5
709931138/mall:redis-3.2
709931138/mall:mongo-3.2
709931138/mall:elasticsearch-5.6.8
709931138/mall:elasticsearch-head-5
709931138/mall:rabbitmq-3.7.8
#erureka-server
#admin-server
#tx-manager
#config-server
#service-member
#service-product
#service-order
http://192.168.5.20:8002/api/order/tx?sn=Q123456&productId=1&memberId=1
#mall-portal
http://192.168.5.20:9001/api/find/data?username=baicai&productSn=SN123456&orderSn=Q123456
http://192.168.5.20:9001/apigateway/member/api/user?username=baicai
http://192.168.5.20:9001/apigateway/product/api/product?sn=SN123456
http://192.168.5.20:9001/apigateway/order/api/order?sn=Q123456
- 此许可证的目的是阻止违反劳动法的公司使用许可证下的软件或代码，并强迫这些公司权衡他们的行为。
- 在此处查看反 996 许可证下的完整项目列表
- 此许可证的灵感来源于 @xushunke：Design A Software License Of Labor Protection -- 996ICU License
- 当前版本反 996 许可证由 伊利诺伊大学法学院的 Katt Gu, J.D 起草；由 Dimension 的首席执行官 Suji Yan 提供建议。
- 该草案改编自 MIT 许可证，如需更多信息请查看 Wiki。此许可证旨在与所有主流开源许可证兼容。
- 如果你是法律专业人士，或是任何愿意为未来版本做出直接贡献的人，请访问 Anti-996-License-1.0。感谢你的帮助。