kafka 中间件服务 Message-Middleware

Apache
Google Go
跨平台
2017-03-11
cdh0805010

消息发布-订阅中间件服务

为了促进产品的平台化建设, 把kafka消息队列从服务中抽象出来。让消息队列只关注消息的订阅和发布,使用微服务,减少与业务逻辑的耦合, 该服务支持多实例部署

使用方法:

只需要在models/grpc_server.go文件中填充要接收的消息体和发送的消息体protocolbuffer,业务逻辑在其他业务逻辑服务中实现, 本项目写了一个与工作有关的订单和短信订阅和发送实例, 其目的是让大家明白怎么样使用该服务。

技术栈
1. [**beego**](https://beego.me/)
2. [**rpcx**](github.com/smallnest/rpcx)
3. [**sarama**](https://github.com/Shopify/sarama)`

Standard  `go get`:

```go
$  go get -v -u github.com/1046102779/message_middleware
```

说明

+ `希望与大家一起成长,有任何该服务运行或者代码问题,可以及时找我沟通,喜欢开源,热爱开源, 欢迎多交流`
+ `联系方式:cdh_cjx@163.com`

加载中

评论(0)

暂无评论

暂无资讯

暂无问答

Ngrx 中 Store 的学习

有一段时间没有更新自己的 blog了,哭(⊙﹏⊙)。其实这段时间接触了很多新知识,只是碎片化地写在了笔记里,但是慢慢久了,就越积越多,现在会找时间,慢慢整理一下,这会有助于我对这些知识...

2018/12/06 17:30
51
0
对django 认证模块的学习

07-05-01) django通过以下中间件提供对认证的支持 'django.contrib.sessions.middleware.SessionMiddleware' 'django.contrib.auth.middleware.AuthenticationMiddleware' 应用模块为 'djang...

2013/08/08 16:01
220
0
10个问题了解JMS

之前一直在对kafka做分析,越深入发现对JMS的理解要求越高,上周出差的时候去海淀买了本书慢慢补一些基础,顺道做些笔记和解释分享上来,这本书网上都有下载,java message service。最近也用...

2013/08/10 11:31
1K
1
django错误 - Reason given for failure: CSRF cookie..

今天练习django的form的提交。当提交表单的时候,出现了 Forbidden (403) CSRF verification failed. Request aborted. Help Reason given for failure:     CSRF cookie not set. In...

2015/05/12 09:27
35
0
webpack热更新原理WebSocket与EventSource

开发环境页面热更新早已是主流,常见的需求如赛事网页推送比赛结果、网页实时展示投票或点赞数据、在线评论或弹幕、在线聊天室等,都需要借助热更新功能,才能达到实时的端对端的极致体验。 ...

2018/04/16 17:31
610
0
activeMQ支持的四种协议简介及性能比较

activeMQ支持的四种协议简介及性能比较

2015/05/27 20:30
8.6K
2
理解Express的routing

# Routing 前面说到,Express的另一个核心特征是routing。什么是routing呢?简单来说,routing可以翻译为“分路”,本质上就是一个HTTP客户端请求与服务器端逻辑的对应关系,左边是HTTP方法+...

2016/08/24 10:10
471
3

没有更多内容

加载失败,请刷新页面

返回顶部
顶部