# activemq

**Repository Path**: ranhaoliu/activemq

## Basic Information

- **Project Name**: activemq
- **Description**: 使用activemq 消息队列为分布式事务提供一个解决方案
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2021-05-15
- **Last Updated**: 2022-06-14

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

### [我的博客](https://blog.csdn.net/weixin_43225966/article/details/116810171)
#### 代码1. TopicProducer 和 TopicSubscriber
 先运行 TopicSubscriber,再运行 TopicProducer
#### 代码2. StompProducer 和 activemq-notify.html
          先运行 activemq-notify.html,
          再运行 StopmProducer
#### 代码3.  除了代码1和代码2 其他都是代码3，代码3是一个分布式事务相关的解决方案

  保证数据库和 消息队列是一个原子操作才能保证分布式事务
 
    (1) 需要用到消息事件表
    (2) 把插入user 和 插入 消息事件表(状态是新建状态) 整体作为一个事务，
    (3) 用户定时器 定时查询事件表，查询到是 新建状态 就 发送给消息队列
    (4) 积分消息队列监听器 监听到消息队列中有消息到来时，将消息插入消息事件表
    (5) 积分定时器(PointScheduled) 定时查询到事件表，查询到PUBLISHED事件后
        执行事件，插入积分列表，更新事件类型
 
### 运行TestDT，