# sim-behavior-message-bus

**Repository Path**: sim-behavior/sim-behavior-message-bus

## Basic Information

- **Project Name**: sim-behavior-message-bus
- **Description**: 行为节点消息发布订阅
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2026-04-13
- **Last Updated**: 2026-04-16

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README


# sim-behavior-message-bus
## 项目简介
sim-behavior-message-bus是仿真行为节点体系的独立轻量化消息总线中台，基于Java开发，采用生产者-路由中心-消费者三层架构，实现全局消息路由、过滤、时序保序、限流消峰、持久化重试，完全解耦节点与底层消息中间件，支持内嵌与独立部署双模式，适配单机/分布式仿真引擎场景，为sim-behavior-core-kernel（内核）、sim-behavior-groovy-engine（脚本引擎）、sim-behavior-admin-web（管理平台）提供统一、高效、可靠的消息通信能力。
## 核心功能
1.  **统一消息通信**：提供标准化消息模型，支持生产者发送、消费者订阅，实现全模块消息互通
2.  **智能路由过滤**：支持按主题、标签、过滤规则路由消息，实现精准消息分发
3.  **时序保序**：确保消息按发送顺序接收处理，满足仿真时序需求
4.  **限流消峰**：滑动窗口限流机制，控制消息流量，避免系统过载
5.  **持久化重试**：关键消息持久化存储，异常消息自动重试，避免消息丢失
6.  **双模式部署**：支持内嵌到内核部署，也可独立部署，适配不同仿真场景
7.  **流量监控**：内置流量埋点，实时统计消息收发数量、限流次数，便于运维监控
## 技术栈
- Java 8+
- Spring Core
- Maven
- Junit 5
## 项目结构
src/main/java/com/sim/behavior/message/bus
├── api/ # 门面接口层（对外极简API）
├── core/ # 核心总线层
│   ├── producer/ # 生产者模块
│   ├── router/ # 路由中心模块
│   ├── consumer/ # 消费者模块
│   ├── limit/ # 限流消峰模块
│   ├── persist/ # 持久化模块
├── config/ # 总线配置类
├── exception/ # 消息处理异常
├── model/ # 消息模型
├── util/ # 工具类
src/test/java # 单元测试
## 环境要求
- JDK 8及以上
- Maven 3.6及以上
## 编译与安装
1.  克隆仓库至本地
2.  确保sim-behavior-core-kernel已打包安装至本地仓库
3.  执行Maven打包命令：`mvn clean install -DskipTests`
4.  打包完成后，可作为依赖引入sim-behavior-core-kernel、sim-behavior-admin-web仓库
## 依赖引入
在关联仓库pom.xml中添加以下依赖：
<dependency>
    <groupId>com.sim.behavior</groupId>
    <artifactId>sim-behavior-message-bus</artifactId>
    <version>1.0.0</version>
</dependency>
## 快速使用
### 内嵌部署（推荐）
1.  在sim-behavior-core-kernel中引入本仓库依赖
2.  配置消息总线参数（路由规则、限流阈值等）
3.  通过门面API调用消息发送、订阅方法，实现模块间通信
### 独立部署
1.  打包本仓库为jar包，通过命令启动：`java -jar sim-behavior-message-bus-1.0.0.jar`
2.  配置其他模块对接独立部署的消息总线地址
3.  正常调用消息通信接口
## 注意事项
1.  本仓库依赖sim-behavior-core-kernel，需与内核版本保持一致
2.  部署模式可通过配置文件切换，内嵌模式适用于单机仿真，独立部署适用于分布式仿真
3.  限流阈值、持久化策略可根据仿真系统性能需求调整
4.  关键消息持久化建议配置文件存储，避免内存溢出
## 版本管理
- 当前版本：1.0.0
- 版本迭代：遵循语义化版本规范，与sim-behavior-core-kernel版本保持一致
- 兼容要求：需与sim-behavior-core-kernel、sim-behavior-groovy-engine、sim-behavior-admin-web版本同步