标签: messaging

我是新来的消息和想知道的区别ActiveMQ,Mule,ServiceMix和Camel

任何人都知道这些产品是如何不同的？

提前致谢 !

编辑:也想知道任何好的地方/资源来学习这些东西.

这两张图片来自http://zguide.zeromq.org/page:all.

如果我们忽略推拉模式中的下沉,这两种模式之间有什么区别？消息的传输方式是否存在差异,如果是,有什么区别？

我想知道当我们引用SOA或中间件时,以及通常在应用程序和企业集成的情况下,消息驱动和事件驱动的环境之间是否有明显的区别.我知道用户界面类似于事件驱动模型,我们的系统拦截用户的操作.

此外,很明显消息传递支持基于发布/订阅,同步或异步通信,事务等的系统.

但是中间件/ soa /应用程序集成上下文有区别吗？(架构级别).我正在尝试咨询维基百科这样的来源(这里和这里),但我仍然有些困惑.开发人员何时应该选择一种解决方案？

是否存在一种方法或案例,其中一种方法比另一种更有意义？或者是否有任何全面的资源和指南来实施每一个？

非常感谢任何见解.

在具有TCP可靠性的UDP广播的答案之一中,用户提到了Spread消息传递API.我还遇到了一个叫做ØMQ的人.我对MPI也很熟悉.

所以,我的主要问题是:为什么我会选择一个而不是另一个呢？更具体地说,当有成熟的MPI实现时,为什么我会选择使用Spread或ØMQ？

我正在研究多媒体应用程序.我正在通过相机捕获一个图像,并希望将带有文本的图像发送到其他一些数字.但我没有得到如何通过彩信发送图像.

在RabbitMQ/AMQP Java客户端中,您可以创建一个AMQP.BasicProperties.Builder,并将其用于build()实例AMQP.BasicProperties.然后,可以将此构建的属性实例用于各种重要事项.此构建器类上有许多"构建器"样式方法:

BasicProperties.Builder propsBuilder = new BasicProperties.Builder();
propsBuilder
    .appId(???)
    .clusterId(???)
    .contentEncoding(???)
    .contentType(???)
    .correlationId(???)
    .deliveryMode(2)
    .expiration(???)
    .headers(???)
    .messageId(???)
    .priority(???)
    .replyTo(???)
    .timestamp(???)
    .type(???)
    .userId(???);

我正在寻找这些builer方法帮助"建立"的字段,最重要的是,每个字段存在哪些有效值.例如,什么是a clusterId,它的有效值是什么？什么是type有效值？等等.

我整个上午都在淘洗:

• Java客户端文档 ; 和
• Javadocs ; 和
• RabbitMQ完整参考指南 ; 和
• AMQP规范

在所有这些文档,我无法找到明确的定义(除了一些含糊的解释是什么priority,contentEncoding以及deliveryMode是)什么的每个领域都,以及他们的有效值.有人知道吗？更重要的是,有人知道这些甚至记录在哪里吗？提前致谢!

我支持需要低延迟(每个消息处理<300微秒)的Java消息传递应用程序.但是,我们的分析显示Sun Java虚拟机最初运行缓慢,并且在前5,000条消息之后加速.前5,000条消息的延迟为1-4毫秒.在大约前5,000个后,后续消息的延迟约为250微秒,偶尔会有异常值.

通常理解这是Java应用程序的典型行为.但是,从业务角度来看,告诉客户他们必须等待JVM"热身"才能看到他们所要求的性能是不可接受的.在处理第一个客户消息之前,应用程序需要"预热"

JVM是Sun 1.6.0 update 4.

克服这个问题的想法:

1. JVM设置,例如-XX:CompileThreshold =
2. 添加组件以在启动时"预热"应用程序,例如通过应用程序发送"假消息".
3. 在应用程序启动时静态加载应用程序和JDK类,以便在处理客户消息时不从JAR加载类.
4. 一些实用程序或Java代理完成上述两个想法中的一个或两个,这样我就不必重新发明轮子了.

注意:显然,对于这个解决方案,我正在考虑所有因素,包括芯片拱,磁盘类型和配置以及操作系统设置.但是,对于这个问题,我想集中讨论如何优化Java应用程序并最大限度地减少"预热"时间.

流处理和传统消息处理之间的基本区别是什么？正如人们所说kafka是流处理的不错选择,但本质上kafka是一个类似于ActivMQ,RabbitMQ等的消息传递框架.

为什么我们通常不会说ActiveMQ也适用于流处理.

是否消费者使用消息的速度决定它是否是流？

我一直在为我的公司评估消息传递技术,但我对几个术语之间的概念差异感到非常困惑:

发布/订阅与多播与扇出 我正在使用以下定义:

• Pub/Sub有发布者向每个订阅者提供每个消息的单独副本,这意味着存在保证传递的机会
• 扇出有一个队列推送到所有侦听客户端.
• 多播只是发送数据,如果有人正在听,那么很好,如果没有,这没关系.没有可能保证客户肯定收到消息.

这些定义是对的吗？或者Pub/Sub模式和组播,直接,扇出等方式来实现模式？

我正在尝试将开箱即用的RabbitMQ定义应用到我们的架构中,但我现在只是试图为我们的应用程序编写规范.

请有人可以告诉我,我是否正确？

我想比较一下grpc与zeromq及其模式的某些功能:我想创建一些比较(功能集) - 不知何故 - 0mq是"更好"的套接字 - 但无论如何 - 如果我应用0mq模式 - 我得到可比的'框架'我认为 - 这里0mq似乎更灵活......

主要要求是:

• 节点之间的异步req/res通信(inproc或远程)
• 灵活的消息路由
• 负载均衡支持
• 有据可查

有任何想法吗？

谢谢!