JJXxXLL

3.2分支会话管理功能详细解析一、改动背景与目标3.2分支（3-2-session-management）的核心目标是为AI微服务网关添加会话管理功能，以支持长连接、实时交互场景，如AI聊天、持续对话等。在3.1分支（3-1-init-project）中，项目仅完成了基础架构搭建，缺乏会话状态管理能力，无法支持需要保持上下文的AI服务交互。 二、具体改动内容1. 新增目录结构1234567891011121314ai-mcp-gateway-domain/└── src/main/java/cn/bugstack/ai/domain/session/ ├── adapter/ │ ├── port/ │ └── repository/ ├── model/ │ ├── aggregate/ │ ├── entity/ │ └── valobj/ │ └── SessionConfigVO.java └── service/ ├── ISessionManagementService.ja ...

Case模块运行机制详解一、整体架构case模块采用了责任链模式和策略模式的组合设计，通过多个节点串联处理MCP会话请求。整体架构如下： 1234567891011121314151617181920212223242526┌─────────────────────────────────────────────────────────────┐│ Case Module ││ ││ ┌──────────────┐ ┌──────────────────────────────┐ ││ │ Service │─────▶│ Session Factory │ ││ │ │ │ │ ││ │ McpMes ...

🚀 ai-mcp-gateway v3.3 版本更新：会话编排架构升级，SSE实时通信能力全面增强 📋 标题选项 从会话管理到会话编排：ai-mcp-gateway v3.3 架构演进实录 责任链模式实战：ai-mcp-gateway v3.3 如何优雅处理SSE会话流程 会话编排架构升级：ai-mcp-gateway v3.3 核心技术解析 🎯 引言在 ai-mcp-gateway v3.2 版本中，我们成功实现了基础的会话管理功能，为AI微服务网关提供了会话状态管理能力。然而，随着业务复杂度的提升，单一的会话管理服务已无法满足多样化的业务场景需求。 在 v3.3 版本中，我们引入了会话编排架构，采用责任链模式重构了会话处理流程，新增了完整的SSE（Server-Sent Events）实时通信能力。本次更新共涉及 22个文件，新增 473行代码，删除 20行代码，标志着项目从”会话管理”迈向”会话编排”的重要里程碑。 ✨ 新特性1. SSE实时通信接口新增了完整的SSE连接建立接口，支持客户端与服务器之间的实时双向通信。 新增接口：12@GetMapping(value ...

深入理解 AI MCP Gateway：从协议演进到网关架构设计 摘要：本文梳理了大模型与企业内部系统交互的技术演进路径，深入分析了传统 Function Calling 模式在企业级落地时的耦合痛点。基于此，提出并设计了 AI MCP Gateway 架构方案，通过动态代理与协议翻译机制，实现现有 HTTP/RPC 接口的零代码接入。文章重点探讨了基于 SSE 的流式传输选型、JSON-RPC 2.0 协议解析及动态路由引擎的设计思路，旨在为企业级 AI 应用提供一套高内聚、低耦合的基础设施解决方案。 1. 引言：大模型落地的“最后一公里”难题在当前的 AI 工程化实践中，我们面临着一个显著的矛盾：大模型（LLM）的通用推理能力与企业内部私有业务数据/服务之间的割裂。 虽然 LLM 具备了强大的逻辑推理和代码生成能力，但它本质上是一个“黑盒”，无法直接访问外部数据库、微服务或遗留系统。为了解决这个问题，业界经历了从 Prompt Engineering 到 Function Calling，再到如今 MCP (Model Context Protocol) 协议的演进。 本文旨在梳 ...

String 还是 Hash 存储对象数据更好呢

1.基础知识1.主键和外键有什么区别?​ 主键是用来唯一标识一条记录的，不能为空也不能重复，一张表只能有一个主键。在 InnoDB 中，主键索引是聚簇索引，数据本身存放在主键索引的叶子节点中。 外键主要用于建立表与表之间的关联关系，用来约束子表中的字段必须来自于父表的主键或唯一键，从而保证数据一致性。外键字段可以重复，也可以为空，一张表可以有多个外键。 在实际生产环境中，一般不直接使用数据库外键，而是在业务层通过逻辑外键来维护数据一致性，以避免外键带来的性能开销和维护复杂度问题。 2.为什么不推荐使用外键与级联？外键和级联主要用于在数据库层面保证数据一致性，但在实际生产环境中通常不推荐使用。 一方面，外键和级联在插入、更新和删除时会带来额外的性能开销，尤其是在高并发场景下影响明显；另一方面，级联操作存在较大的误操作风险，一次错误删除可能导致大量数据被级联删除。 此外，外键不适用于分库分表和微服务架构，会增加系统的耦合度和维护成本。 因此，在实际项目中通常采用逻辑外键，在业务层通过代码和事务来保证数据一致性，而不是依赖数据库外键和级联机制。 什么是存储过程存储过程是一组预先编译并 ...

IoC有什么用？ 第一层（核心定义）：“IoC将对象创建和依赖管理的控制权从程序代码反转到容器，实现了解耦。我的类不再new依赖对象，而是通过构造器、Setter或字段声明它需要什么，容器在运行时注入给它。” 第二层（具体价值）：“它带来了四个关键好处：第一是解耦，让我的业务代码只依赖接口，便于替换实现。第二是易于测试，我可以轻松注入Mock对象进行单元测试。第三是集中管理，所有对象的生命周期由容器统一管理，更安全。第四是配置灵活，通过修改配置就能改变组件行为和依赖关系。” 第三层（结合实践）：“比如在我的项目中，OrderService依赖PaymentService。利用IoC，我只需用@Autowired声明依赖。当需要从微信支付切换到支付宝时，我只需配置不同的PaymentService实现Bean，OrderService的代码一行都不用改，这极大地提升了维护性和扩展性。”

MySQL 1234567<update id="updateAddLockCount" parameterType="java.lang.String"> <![CDATA[ update group_buy_order set lock_count = lock_count + 1, update_time= now() where team_id = #{teamId} and lock_count < target_count ]]></update> 责任链模型结构

为了拆分库表，为了省事在xml文件中直接注释： 12345678910 <select id="queryValidGroupBuyActivityId" resultMap="GroupBuyActivityMap"> SELECT activity_id, activity_name,-- source, channel, goods_id, discount_id, group_type, take_limit_count, target, valid_time, status, start_time, end_time, tag_id, tag_scope FROM group_buy_activity-- WHERE source = #{source} AND channel = #{channel} WHERE activity_id = #{acti ...

👍 很好，这一步你已经精准定位到“真正的根因”了。而且这个问题非常典型、非常高级，不是新手能一下子意识到的。 我给你把这件事一次性讲透👇 一、结论先行（你这次为什么会 NPE） ❌ 不是 SQL 查不到数据 ❌ 不是多线程问题 ✅ 是 MyBatis 映射方式用错了：resultType vs resultMap 你原来的 SQL 能查到行，但是 MyBatis 没有把字段正确映射到 Java 对象里，导致： 123groupBuyActivityRes != null但groupBuyActivityRes.getDiscountId() == null 于是后面必炸 💥 二、你现在这两段 SQL 的“本质区别”❌ 原来（有问题的）12<select id="queryValidGroupBuyActivity" resultType="cc.jxlll.infrastructure.dao.po.GroupBuyActivity"> ✅ 现在（正确的）12<select id="query ...

设计模式 先看左侧， 1234策略路由抽象类 AbstractStrategyRouterT 入参类型D 上下文参数R 返参类型 1234567891011121314public abstract class AbstractStrategyRouter<T,D,R> implements StrategyHandler<T,D,R>,StrategyMapper<T, D, R> { StrategyHandler<T,D,R> defaultStrategyHandler = StrategyHandler.DEFAULT; public R router(T requestParameter, D dynamicContext) throws Exception { StrategyHandler<T,D,R> strategyHandler = get(requestParameter, dynamicContext); if(null != strate ...

新增TagNode节点，进行过滤：过滤逻辑： 没配置tag_id，就是不筛选人群，所以用户全都可见可参与；配置了tag_id，就是要筛选人群 如果用户在人群标签中直接放行，可见可参与；不在此人群标签中要看tag_scope的配置 如果tag_scope为空就是不做限制，所以也全都可见可参与；如果tag_scope有值，则代表做限制 包含 “1” → 不可见（visible=false） 包含 “2” → 不可参与（enable=false） 动态配置开关操作何不停车就给汽车换个轮子？ 这是互联网应用程序中经常干的事情，在程序运行过程中，直接动态变更某些属性配置。这些动态变更的配置包括降级和切量的开关，也包括一些功能程序的白名单用户测试。 那么对于配置中心，有 SpringCloud Config + Event Bus，也有 Nacos，还有各个大厂中会基于各类组件做的自研实现。那么本节我们先来做一个基于 Redis 发布/订阅处理动态配置的自研的实现，之后对于 SpringCloud 的动态配置变更已经有案例，小伙伴也可以学习。 1.引入两个概念:降级和切片 ...