设计一个publish/subscribe service - 未名空间MITBBS历史存档

国际科技财经博客移民网络热点娱乐民生时事公众号

Redian新闻

>未名空间

>Programming - 葵花宝典

设计一个publish/subscribe service

设计一个publish/subscribe service# Programming - 葵花宝典

t*o2016-10-07 07:10

1 楼

是不是看一点就行，不用看版上讨论的这么难的算法题了？谢谢

n*o2016-10-07 07:10

2 楼

如果每个月都能前进4个月的速度就爽了。:-)

t*y2016-10-07 07:10

3 楼

要买的房子DRIVE WAY有几条横条的CRACKS,就是裂开了.还有一些碎纹.不知道该怎么修
呢?大概要多少钱?卖家不愿意修.

p*82016-10-07 07:10

4 楼

需求如下：
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
谢谢大牛！

c*u2016-10-07 07:10

5 楼

个人观点，找.net的工作，经验比什么都重要，应该不会太考察算法

【在 t****o 的大作中提到】

: 是不是看一点就行，不用看版上讨论的这么难的算法题了？谢谢

D*r2016-10-07 07:10

6 楼

祝愿美梦成真！

b*s2016-10-07 07:10

7 楼

concrete calk, lowe's homedepot, $10左右,自己补.

【在 t*****y 的大作中提到】

: 要买的房子DRIVE WAY有几条横条的CRACKS,就是裂开了.还有一些碎纹.不知道该怎么修
: 呢?大概要多少钱?卖家不愿意修.

s*o2016-10-07 07:10

8 楼

现有的各种message library满足不了需求吗？kafka, rabbitmq, activemq, ...

c*s2016-10-07 07:10

9 楼

同梦

m*e2016-10-07 07:10

10 楼

内容是动态的，并且会变化，这个service需要告知现在有哪些内容可以subscribe,
consumer 端需要封装可供选择的action, message queue 更偏向于有没有新消息吧？

【在 s***o 的大作中提到】

: 现有的各种message library满足不了需求吗？kafka, rabbitmq, activemq, ...

B*i2016-10-07 07:10

11 楼

同梦

w*z2016-10-07 07:10

12 楼

你这需求实在看不懂。内容是动态的，啥意思？

【在 m**********e 的大作中提到】

: 内容是动态的，并且会变化，这个service需要告知现在有哪些内容可以subscribe,
: consumer 端需要封装可供选择的action, message queue 更偏向于有没有新消息吧？

w*m2016-10-07 07:10

13 楼

把代码json话，放到message queue里面
就是task queue

c*e2016-10-07 07:10

14 楼

redis不行吗?

【在 s***o 的大作中提到】

: 现有的各种message library满足不了需求吗？kafka, rabbitmq, activemq, ...

H*S2016-10-07 07:10

15 楼

rxjava + rxnetty, you basically need a hot observable that serves all
subscribers either locally or remotely.

p*22016-10-07 07:10

16 楼

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*e2016-10-07 07:10

17 楼

这个是正解。

【在 s***o 的大作中提到】

: 现有的各种message library满足不了需求吗？kafka, rabbitmq, activemq, ...