2024-11-14

说明

Seata 是阿里巴巴开源的分布式事务中间件，以高效并且对业务 0 侵入的方式，解决微服务场景下面临的分布式事务问题。 Seata 将为用户提供了 AT、TCC、SAGA 和XA 事务模式，为用户打造一站式的分布式解决方案。AT模式是阿里首推的模式,阿里云上有商用版本的GTS（Global Transaction Service 全局事务服务）。

github地址

AT模式

在 AT 模式下，用户只需关注自己的“业务 SQL”，用户的 “业务 SQL” 作为一阶段，Seata 框架会自动生成事务的二阶段提交和回滚操作。

Server 端存储模式（store.mode）支持三种方式：

file：单机模式（默认为此模式），全局事务会话信息存储在内存中，读写并持久化至本地文件 root.data （bin\sessionStore\root.data) 中，性能较高。 db：高可用模式（Mysql 5.7+），全局事务会话信息通过db共享，相应性能差些。 redis：Seata-Server 1.3及以上版本支持，性能较高，但存在事务信息丢失风险，请提前配置适合当前场景的redis持久化配置。

创建 undo_log 表

Seata AT 模式需要使用到 undo_log 表。

sql
-- 注意此处0.3.0+ 增加唯一索引 ux_undo_log
CREATE TABLE `undo_log` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `branch_id` bigint(20) NOT NULL,
  `xid` varchar(100) NOT NULL,
  `context` varchar(128) NOT NULL,
  `rollback_info` longblob NOT NULL,
  `log_status` int(11) NOT NULL,
  `log_created` datetime NOT NULL,
  `log_modified` datetime NOT NULL,
  `ext` varchar(100) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

2024-11-14

Service Interface

IService 是 MyBatis-Plus 提供的一个通用 Service 层接口，它封装了常见的 CRUD 操作，包括插入、删除、查询和分页等。通过继承 IService 接口，可以快速实现对数据库的基本操作，同时保持代码的简洁性和可维护性。

IService 接口中的方法命名遵循了一定的规范，如 get 用于查询单行，remove 用于删除，list 用于查询集合，page 用于分页查询，这样可以避免与 Mapper 层的方法混淆。

保存

save
saveBatch
saveOrUpdate
saveOrUpdateBatch

删除

remove
removeById
removeByIds
removeByMap

更新

update
updateById
updateBatchById

查询

get
getOne
getById
getObj
list
listByIds
listByMap
listMaps
page
count

2024-11-12

前提

wsl中不配置互通，一个docker服务不能通过localhost地址访问另外的服务

配置

打开或创建位于 %UserProfile% 目录下的 .wslconfig 文件（例如 C:\Users\你的用户名.wslconfig）。


[wsl2]
memory=4GB                        # 分配给 WSL 2 的内存大小
processors=2                      # 分配给 WSL 2 的 CPU 核心数
localhostForwarding=true          # 是否启用 localhost 转发
 
[experimental]
autoMemoryReclaim=gradual         # 开启自动回收内存，可在 gradual, dropcache, disabled 之间选择
networkingMode=mirrored           # 开启镜像网络
dnsTunneling=true                 # 开启 DNS Tunneling
firewall=true                     # 开启 Windows 防火墙
autoProxy=true                    # 开启自动同步代理
sparseVhd=true                    # 开启自动释放 WSL2 虚拟硬盘空间

重启服务

管理员身份运行PowerShell：

停止WSL： wsl --shutdown

启动WSL： wsl

2024-11-12

提示


org.apache.tomcat.util.http.fileupload.impl.FileSizeLimitExceededException: 
The field file exceeds its maximum permitted size of 1048576 bytes.

这个错误信息表明你上传的文件大小超过了Tomcat服务器允许的最大限制。默认情况下，Tomcat对文件上传的大小有限制，通常是1MB（1048576字节）。

解决方法

application.yml增加文件大小的配置

yml
spring:
  servlet:
    multipart:
      max-file-size: 20MB
      max-request-size: 20MB

java配置类

java

import org.springframework.boot.web.servlet.MultipartConfigFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.util.unit.DataSize;

import javax.servlet.MultipartConfigElement;

@Configuration
public class FileUploadConfig {

    @Bean
    public MultipartConfigElement multipartConfigElement() {
        MultipartConfigFactory factory = new MultipartConfigFactory();
        // 设置单个文件最大值
        factory.setMaxFileSize(DataSize.ofMegabytes(2)); // 2MB
        // 设置总上传数据总大小
        factory.setMaxRequestSize(DataSize.ofMegabytes(2)); // 2MB
        return factory.createMultipartConfig();
    }
}

阅读全文

Alibaba微服务分布式消息-RocketMQ

编辑

2024-11-08

实用工具

说明

RocketMQ 是一款开源的分布式消息系统，基于高可用分布式集群技术，提供低延时的、高可靠的消息发布与订阅服务。

Spring Cloud Stream 是一个用于构建基于消息的微服务应用框架。它基于 SpringBoot 来创建具有生产级别的单机 Spring 应用，并且使用 Spring Integration 与 Broker 进行连接。

Spring Cloud Stream 提供了消息中间件配置的统一抽象，推出了 publish-subscribe、consumer groups、partition 这些统一的概念。

Spring Cloud Stream 内部有两个概念：Binder 和 Binding。

Binder: 跟外部消息中间件集成的组件，用来创建 Binding，各消息中间件都有自己的 Binder 实现。

比如 Kafka 的实现 KafkaMessageChannelBinder，RabbitMQ 的实现 RabbitMessageChannelBinder 以及 RocketMQ 的实现 RocketMQMessageChannelBinder。

Binding: 包括 Input Binding 和 Output Binding。

Binding 在消息中间件与应用程序提供的 Provider 和 Consumer 之间提供了一个桥梁，实现了开发者只需使用应用程序的 Provider 或 Consumer 生产或消费数据即可，屏蔽了开发者与底层消息中间件的接触。文档

下载并启动

下载地址

启动 Name Server


sh bin/mqnamesrv

启动 Broker


sh bin/mqbroker -n localhost:9876

阅读全文