Merge branch 'master' of https://git.trustie.net/Gitlink/gitlink-notification-system into dev_gitlink_model
# 请输入一个提交信息以解释此合并的必要性,尤其是将一个更新后的上游分支 # 合并到主题分支。 # # 以 '#' 开始的行将被忽略,而空的提交说明将终止提交。
This commit is contained in:
commit
81dff44d81
20
README.md
20
README.md
|
|
@ -1,13 +1,13 @@
|
|||
|
||||

|
||||

|
||||
|
||||
### 主要组成部分:
|
||||
|
||||
1. **xxl-job 调度管理中心** :提供对分布式的任务集中监控、管理等功能
|
||||
2. **xxl-job 执行器** :消息中心的业务逻辑实现,目前只实现「系统通知」功能,后续可以考虑 `email-executor`、`text-message-executor` 等实现
|
||||
3. **GNS-Writer**:给 `Forge业务层` 调用的 API 网关,负责从业务逻辑层接受信息
|
||||
1. **管理后台(在建)** :提供对分布式的任务集中监控、管理等功能
|
||||
2. **各类执行器** :消息中心的业务逻辑实现,目前只实现「系统通知」和「邮件通知」功能,后续可以考虑短信通知、微信通知等实现
|
||||
3. **GNS-Writer**:给 `业务层` 调用的 API 网关,负责从业务逻辑层接受信息
|
||||
4. **middleware**:独立运行的中间件服务, 包括消息中间件、缓存中间件、DB
|
||||
5. **GNS-Reader**:给 `Forge业务层` 调用的 API 网关,负责提供业务数据
|
||||
5. **GNS-Reader**:给 `业务层` 调用的 API 网关,负责提供业务数据
|
||||
|
||||
### 一些约定:
|
||||
|
||||
|
|
@ -22,4 +22,14 @@
|
|||
3. 在本地分支修改任务并推送到自己名下的仓库
|
||||
4. 在 [仓库首页](https://forgeplus.trustie.net/projects/Gitlink/gitlink-notification-system) 触发 pull request 并等待审核处理
|
||||
|
||||
### 使用 Docker 运行
|
||||
1. git pull 拉取本仓库并保存到本地
|
||||
2. 下载并安装 [Docker Engine](https://docs.docker.com/engine/install/)
|
||||
3. 配置好 Java 环境以及 Maven 环境 (Java 8 版本以上、Maven 3 版本以上)
|
||||
4. 进入到仓库根目录下的 `{repo}/middleware` 目录并执行 `start_docker_compose.sh` 脚本
|
||||
5. 浏览器访问
|
||||
1. 数据推送相关接口:http://localhost:58082/doc.html
|
||||
2. 数据读取相关接口:http://localhost:58080/doc.html
|
||||
6. 停止 Docker 时环境时请执行 `{repo}/middleware/end_docker_compose.sh` 脚本
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -14,7 +14,7 @@ import org.springframework.stereotype.Component;
|
|||
@Component
|
||||
@Configuration
|
||||
//todo 邮件的topics和groupId待处理
|
||||
@KafkaListener(topics = "${spring.kafka.consumer.topic}", groupId = "${spring.kafka.consumer.group_id}")
|
||||
//@KafkaListener(topics = "${spring.kafka.consumer.topic}", groupId = "${spring.kafka.consumer.group_id}")
|
||||
public class EmailJobsListener {
|
||||
|
||||
private Logger logger = LogManager.getLogger(EmailJobsListener.class);
|
||||
|
|
|
|||
Loading…
Reference in New Issue