消息传递，队列和ESB-我知道我想去哪里，但不知道如何到达那里
总而言之，我正在一个项目中，出于所有通常的原因，我们正在重写一个大型Web应用程序.重写的主要目的是将在单个服务器上运行的大型单个应用程序分离为许多较小的，已解耦的应用程序，这些应用程序可以在多个服务器上运行. 好，这就是我想要的: 我希望HTTP是主要的运输机制.当一个应用程序(例如CMS)已更新时，它将通过http与经纪人联系并说 "I've changed" ，然后经纪人将发回
..
messaging相关内容
在队列RabbitMQ之间移动消息
我希望能够在Rabbit中的队列之间(手动)移动消息. 例如: first-queue has messages ['a','b','c','d','e','f'] second-queue has messages ['x','y'] 我希望能够将例如消息"a"从第一队列移至第二队列.这可以是手动操作.两个队列都在同一个代理上，我不想通过任何交换发送它们.反正有这样做吗?我一直在
..
如何实施竞争性的消费者解决方案?
作为练习，我试图找到一个实现竞争消费者的示例. 许多生产者-> MSMQueue
..
在目标应用程序在C ++中崩溃的情况下，无法使用LVM_GETITEMTEXT
我正在尝试从另一个应用程序从SysListView32类(根据Spy ++)捕获数据.向此句柄发送LVM_GETITEMCOUNT消息总是返回正确数量的项目.有一个子窗口是SysHeader32，该窗口可能包含标题标题. 当我尝试向目标应用程序发送LVM_GETITEMTEXT消息时，它崩溃了.此消息的相关代码如下: LPTSTR lpText; LVITEM* lvItem; lvI
..
select()是如何被提醒到fd变为“就绪"的?
我不知道为什么很难找到这个，但是我正在看一些Linux代码，我们在其中使用select()等待文件描述符来报告它已经准备好了.在选择的手册页中: select() and pselect() allow a program to monitor multiple file descriptors, waiting until one or more of the file descripto
..
Laravel 4关系:消息传递系统
我遵循了ehp用户的建议，以构建一个轻量级的消息传递系统: https://stackoverflow.com/a/18717864/1084315 Users: id | username Messages: id | from | content user_messages: user_id | message_id class User extends Eloquent
..
Laravel推送通知和消息传递
我试图用laravel用后端离子写前端. 我想做的是，当用户订购应用程序时，我想向应用程序发送通知，并从应用程序中与用户进行消息传递. 为此，我已经审查了/laravel-push-notification包； 但是，它对我不起作用，因为我需要动态消息传递.你能帮忙吗?我不想使用 https://pusher.com 解决方案 我还使用以下代码在laravel中集成了推送通知，
..
Kafka基于键/值对的消息传递的目的是什么?
producer.send(new ProducerRecord("someTopic", Integer.toString(i), Integer.toString(i))); 但是在Kafka文档中，我似乎找不到解释键/值概念(及其潜在目的/效用)的地方.在传统的消息传递中(ActiveMQ，RabbitMQ等)，我总是在特定的主题/队列/交换中触发一条消
..
在哪里可以找到有关Mach内核消息传递的良好文档
我正在寻找全面的信息 1)Mach消息传递(mach_msg函数和朋友) 2)Mig系统(mig_get_reply_port函数和朋友) 我发现了以下内容: a)不同的开源代码(例如 http: //opensource.apple.com/source/Libc/Libc-167/threads.subproj/mig_support.c ) b)本文仅作简要概述
..
Kafka制作人可以创建主题和分区吗?
当前，我正在评估不同的消息传递系统. 有一个与Apache Kafka有关的问题，我无法回答自己. Kafka制作人是否可以动态创建主题和分区(以及现有主题)? 如果是，那么它是否有任何不利之处? 预先感谢 解决方案 已更新: kafka经纪人具有以下财产: auto.create.topics.enable 如果生产者将消息发布到具有新主题名称的主题，则将其设置为
..
Kafka生产者-如何在不停机且不保留消息顺序的情况下更改主题?
这个问题是关于架构和kafka主题的迁移. 原始问题:没有向后兼容性的架构演进. https://docs.confluent.io/current/schema-registry /avro.html 我正在要求社区提供建议或分享文章，从中我可以得到启发，甚至可以考虑解决问题的方法.也许有架构或流模式.不必为我提供特定于语言的解决方案；只是给我一个方向，我可以去...我的问题很
..
Kafka如何保证消费者跨分区处理的消息排序?
来源: https://kafka.apache.org/intro “通过在主题内具有并行性(即分区)的概念， Kafka能够提供订购保证和负载平衡 消费者流程池中.这是通过分配 将主题划分给消费者组中的消费者，以便 每个分区仅由组中的一个使用者使用.经过 这样做，我们确保消费者是该产品的唯一读者 分区并按顺序使用数据. " 这仅意味着每个使用者将按顺序处理消息，但是在同一使用者组中
..
jGrowl:如何将我的界面一次限制为一条消息?
鉴于:我在页面加载时加载了消息队列. 使用jGrowl，我如何以点滴状的方式一次显示一条消息? 解决方案 几个月前，我需要为一个项目执行此操作.如果您使用最新jGrowl(在撰写本文时为1.2.0)中提供的池化功能，则只需编写以下内容即可: $.jGrowl.defaults.pool = 1; 这样，您可以同时加载所有这些文件，jGrowl会一次只显示一个.消息关闭时，j
..
JMS确认异步消息
使用消息监听器时如何确认消息? 当我尝试在消息侦听器中进行确认时，出现以下错误. A synchronous method call is not permitted when a session is being used asynchronously: 'acknowledge' 解决方案 您在谈论JMS消息确认，如该错误似乎有点奇怪.如果您不使用事务处理或自动确认，那么我认
..
Kafka是否具有“持久订阅"功能?
我有兴趣在我的一个项目中使用Kafka，但是有一个要求，当一个订户(使用者)断开连接时，消息传递代理必须保留消息. 我看到JMS具有功能. 在网站上说，Kafka具有耐久性功能. 与JMS一样还是具有不同的含义? 解决方案 消费者从kafka(经纪人)中提取数据.消费者指定要从其收集数据的位置开始的偏移量.如果Consumer断开连接并回来，它可以在离开的地方继续.它还可
..
什么是“交易工作单元"?用简单的英语?
该问题直接来自SO中的我之前的问题.我仍然无法理解将JMS会话用作事务性工作单元的概念. 从 Java消息服务本书中: QueueConnection对象用于创建JMS会话对象 (特别是队列会话)，它是工作线程， JMS中的事务性工作单元.与JDBC不同，JDBC需要一个 每个事务性工作单元的连接，JMS使用单个 连接和多个Session对象.通常，应用程序将 在应用程序启动时创建单个
..
与竞争的消费者顺序处理消息
问题: 我以特定顺序(FIFO)接收队列中的消息(例如订单) 我的竞争对手正在排队 为进一步增加复杂性，消费者可能仅根据订单的状态对订单的特定版本感兴趣.(例如，version1，version 2和version5) 订单上的订单版本号可用，但不能用于排序，因为我的侦听器可能对所有版本都不感兴趣(消费者可能只对版本1，版本2和版本5感兴趣) 如何确保我按接收者的顺序处理消费者中
..
如何在Weblogic 11g上设置到ActiveMQ的JMS桥
我是Java EE堆栈的JCA和JMS部分的新手，现在我在两个JMS提供程序(ActiveMQ 5.9.1-> Weblogic 11g 10.3)之间的 JMS桥配置上苦苦挣扎. 5)，并且我需要一些帮助来了解所有活动部件和所需的配置元素. 我已经完成的工作: 在Weblogic 11g节点上配置的JMS服务器 已配置的外部服务器-AMQ连接工厂，以及绑定到本地JNDI的源队列
..
带有和不带有Spring JMS的AUTO_ACKNOWLEDGEMENT模式之间的区别
我试图了解确认模式在JMS中的工作方式.我正在阅读此资源，但与Spring文档所说的相矛盾，这使我非常困惑. 有消息说一件事: 来自 http://www. javaworld.com/article/2074123/java-web-development/transaction-and-redelivery-in-jms.html 成功从receive()方法返回消息后，将自动对其
..
JMS消息仅在消息被确认之前确认
如何确保消息确认仅删除直到在jms代理中调用了确认的消息为止的消息. 目前，我有一个从jms队列中消费并对其进行部分处理的系统.有时稍后，这些消息的批处理将被另一个线程保留.我现在需要确认消息.但是问题是我必须停止使用这些消息，否则，确认先前收到的消息还将确认收到的所有其他后续消息. 换句话说，假设我在队列中有10条消息.我消耗了其中的7个，然后在第5条消息中确认.反过来，这会将使用者收到的
..