p*******8
发帖数: 344 | 1 需求如下：
language: java
scalable
rerun task when it's failed
基本概况：现在有些service需要publish content以便其他的service consume，所以
需要一个service能够接收publisher publish的content, 一旦这个内容有变化，
notify 所有consumer，notify的action有可能是发email, trigger api，取决于
consumer subscribe的时候的选择，怎样能够让他scalable? 一次有且仅有一个worker
会notify， 如果fail了，自动rerun。大致的diagram 如下：
publisher1 publisher2
| |
| -----------------------------------------|
|
|
|------------------------------------------|
| |
consumer1 consumer2
谢谢大牛！ |
s***o
发帖数: 2191 | 2 现有的各种message library满足不了需求吗？kafka, rabbitmq, activemq, ... |
m**********e
发帖数: 52 | 3 内容是动态的，并且会变化，这个service需要告知现在有哪些内容可以subscribe,
consumer 端需要封装可供选择的action, message queue 更偏向于有没有新消息吧？
【在 s***o 的大作中提到】
: 现有的各种message library满足不了需求吗？kafka, rabbitmq, activemq, ...
|
w**z
发帖数: 8232 | 4 你这需求实在看不懂。内容是动态的，啥意思？
【在 m**********e 的大作中提到】
: 内容是动态的，并且会变化，这个service需要告知现在有哪些内容可以subscribe,
: consumer 端需要封装可供选择的action, message queue 更偏向于有没有新消息吧？
|
w********m
发帖数: 1137 | 5 把代码json话，放到message queue里面
就是task queue |
c*********e
发帖数: 16335 | 6 redis不行吗?
【在 s***o 的大作中提到】
: 现有的各种message library满足不了需求吗？kafka, rabbitmq, activemq, ...
|
H****S
发帖数: 1359 | 7 rxjava + rxnetty, you basically need a hot observable that serves all
subscribers either locally or remotely. |
p*****2
发帖数: 21240 | 8
worker
这个可以用akka做吧？
【在 p*******8 的大作中提到】
: 需求如下：
: language: java
: scalable
: rerun task when it's failed
: 基本概况：现在有些service需要publish content以便其他的service consume，所以
: 需要一个service能够接收publisher publish的content, 一旦这个内容有变化，
: notify 所有consumer，notify的action有可能是发email, trigger api，取决于
: consumer subscribe的时候的选择，怎样能够让他scalable? 一次有且仅有一个worker
: 会notify， 如果fail了，自动rerun。大致的diagram 如下：
: publisher1 publisher2
|
c*********e
发帖数: 16335 | 9 这个是正解。
【在 s***o 的大作中提到】
: 现有的各种message library满足不了需求吗？kafka, rabbitmq, activemq, ...
|
