路人甲(17630319) 09:56:59
有人用过java实现的消息总线么？
Zhongwm(52208468) 10:03:54
具体的
路人甲(17630319) 09:59:18
不是询问商业产品，而是有没有在系统中有类似的设计？java中有相关的规范jbi，还没有看完
Kei(上海猎头)(8765424) 10:00:18
c++做过不少总线。java每写过。其他人写的。有什么问题？
铁手(28730869) 10:02:01
ActiveMQ
Kei(上海猎头)(8765424) 10:02:12
1.消息总线成为瓶颈的时候如何进行负载上的扩容？
2.消息总线如何支持分布式处理？
3.消息总线是否可以保证可靠的消息传输?
考虑了这些方面么？ 
Kei(上海猎头)(8765424) 10:02:18
都考虑了
Kei(上海猎头)(8765424) 10:02:29
1负载扩展
Kei(上海猎头)(8765424) 10:02:41
有2种做法。
Kei(上海猎头)(8765424) 10:04:07
1种是有中心节点的集群。不过会有单点故障。可以采用选举式的分布算法来选举中心节点。不过比较复杂我们没采用
路人甲(17630319) 09:56:59
有人用过java实现的消息总线么？
Zhongwm(52208468) 10:03:54
具体的
路人甲(17630319) 09:59:18
不是询问商业产品，而是有没有在系统中有类似的设计？java中有相关的规范jbi，还没有看完
Kei(上海猎头)(8765424) 10:00:18
c++做过不少总线。java每写过。其他人写的。有什么问题？
铁手(28730869) 10:02:01
ActiveMQ
Kei(上海猎头)(8765424) 10:02:12
1.消息总线成为瓶颈的时候如何进行负载上的扩容？
2.消息总线如何支持分布式处理？
3.消息总线是否可以保证可靠的消息传输?

考虑了这些方面么？ 
Kei(上海猎头)(8765424) 10:02:18
都考虑了
Kei(上海猎头)(8765424) 10:02:29
1负载扩展
Kei(上海猎头)(8765424) 10:02:41
有2种做法。
Kei(上海猎头)(8765424) 10:04:07
1种是有中心节点的集群。不过会有单点故障。可以采用选举式的分布算法来选举中心节点。不过比较复杂我们没采用
ytam--白粉(6159416) 10:05:39
类似p2p的DHT的做法试过没，呵呵，全分布
Kei(上海猎头)(8765424) 10:06:02
2是增加节点时。保持新节点与原来所有节点的连接。这样某个节点收到消息后，需要马上同步到其他节点。里面要注意消息的序列问题，需要共享一个全局序列好
Kei(上海猎头)(8765424) 10:08:45
多机器还要自己设计路由算法
路人甲(17630319) 10:09:42
总线上支持每秒多少个消息？消息支持同步和异步么？
ytam--白粉(6159416) 10:09:46
一个全局序列？你们是维持causal order还是真正的gobal order?
Kei(上海猎头)(8765424) 10:12:31
呵呵。刚确认了以下。我们做的那个不保证序列的。不好意思
Kei(上海猎头)(8765424) 10:13:40
序列是应用上保证的。这样通讯中间件作起来容易。不过某些商业产品是保证各个节点的消息序列是一致的。
Kei(上海猎头)(8765424) 10:14:37
做法一旧可以保证。由中心节点来仲裁。中心节点需要热辈分保证不出现单点故障
ytam--白粉(6159416) 10:14:49
哦。我以为你们保证的是各节点内的total order，那就要用定序器类似的东西，比较麻烦，而且性能会...
Kei(上海猎头)(8765424) 10:15:18
是的。所以自己没有做
Kei(上海猎头)(8765424) 10:16:14
总线上支持每秒多少个消息？消息支持同步和异步么？ 没有统计过。支持异步。
 
ytam--白粉(6159416) 10:16:22
causal order应该满足吧，不然就不满足因果关系还是比较麻烦di，而且causal order实现高效哦
Kei(上海猎头)(8765424) 10:16:56
什么市causal order?不知道这个名词什么意思？
ytam--白粉(6159416) 10:17:06
比较羡慕kikin做过那么多实际的通信系统，呵呵
Kei(上海猎头)(8765424) 10:17:54
呵呵。身边强人多。跟着学的而已。
ytam--白粉(6159416) 10:18:03
因果顺序，就是如果一个节点是收到消息A才发消息B的话，那么集群内各节点都保证先收A再收B
Kei(上海猎头)(8765424) 10:18:28
这个可以保证的
Kei(上海猎头)(8765424) 10:18:45
和我想的意思一样。呵呵
ytam--白粉(6159416) 10:19:07
就是啊，不然因果关系都不满足了。
Kei(上海猎头)(8765424) 10:19:52
每个节点都保证自己的消息序列的
ytam--白粉(6159416) 10:20:20
始终觉得这些系统一定要实际做过才好，不然怎么研究是个理想的东西，好象我
Kei(上海猎头)(8765424) 10:21:16
3.消息总线是否可以保证可靠的消息传输?
当染能支持。不过做的好的能够提供3种程度的支持。我们只实现最大程度支持和最小程度支持
邢红瑞(50128986) 10:21:33
可以并发吗
 
邢红瑞(50128986) 10:22:00
我作过单线程的，效率还可以
kevin(14425285) 10:22:12
请问一下：hibernate中的Example对于日期是如何操作的？
蒋蓉生(1250393) 10:23:04
date 还是 datetime ?
蒋蓉生(1250393) 10:23:25
date 就是用 date
datetime 就用 timestamp
Kei(上海猎头)(8765424) 10:23:27
你的并发指什么？对单个节点来说，单县城处理和多县城处理我都做过。更倾向单县城，效率更高
kevin(14425285) 10:23:37
TimestampType
ytam--白粉(6159416) 10:23:44
这个消息传输可靠性，是单纯消息通信过程的可靠性，还是消息本身的可靠性？就是总线系统crash后仍保证？
kevin(14425285) 10:23:48
怎么弄？！
kevin(14425285) 10:24:11
Example的enableLike默认是字符的
邢红瑞(50128986) 10:24:18
总线系统crash后仍保证
Kei(上海猎头)(8765424) 10:24:20
对单个节点，单县城和多县城都能提供异步操作。旧可以了
邢红瑞(50128986) 10:24:36
我是不是，白痴
 
蒋蓉生(1250393) 10:24:57
映射文件中 用 type="timestamp" 表示
kevin(14425285) 10:25:12
这个我知道
kevin(14425285) 10:26:00
现在映射没有问题，我是想用hibernate提供的Example来建立criteria
蒋蓉生(1250393) 10:26:08
程序里面直接保存 date 实例
kevin(14425285) 10:26:31
 
蒋蓉生(1250393) 10:26:34
用来做比较？
kevin(14425285) 10:26:47
Example ex = Example.create(p).ignoreCase().enableLike(
    MatchMode.ANYWHERE);
  Criteria criteria = getSession().createCriteria(President.class).add(ex);
kevin(14425285) 10:26:53
比如这里直接就创建了criteria
kevin(14425285) 10:27:16
但是这里只能对字符串的like
Kei(上海猎头)(8765424) 10:27:22
我还没说完3种可靠性措施呢。1种是不保证可靠到达。性能最好1种是若保证。消息内容在内存缓存，当节点crash旧不能保证可靠到达。3就是保存在文件中。crash后根据队列重新恢复
kevin(14425285) 10:27:26
date的like会报错
蒋蓉生(1250393) 10:27:42
呵呵，刚才没有弄明白问题 sorry
Kei(上海猎头)(8765424) 10:27:46
其实做法都很多种。看具体应用需要
kevin(14425285) 10:27:55
也谢谢你呀：）
邢红瑞(50128986) 10:28:27
今天看到kei真正水平
Kei(上海猎头)(8765424) 10:28:37
。。。
蒋蓉生(1250393) 10:29:22
没做过比较日期的