2回答
解同步
、、、
我想用一个同步来解决消息队列
在消息队列的wikipedia页面中，我看到：
大多数消息传递系统都支持API中的发布服务器/订阅服务器和消息队列模型。
我使用python(芹菜在过去)，乐趣和成功。
……但我不明白“publisher/订户”和“消息队列模型”之间的(学术)区别。
“publisher/订户”和“消息队列模型”之间有什么区别？
浏览 0提问于2017-04-10得票数 2
1回答
AMQP中的消息路由
、、、
我想用AMQP做一些路由魔术。我的设置是带有Pika的Python，它位于消费者/生产者端，RabbitMQ用于AMQP服务器。
我想要达到的目标：
向单个魔术发送消息)使用如下所示的消息：
- one set of subscribers should be able to retrieve based on a routing key
- one set of subscribers should just get all messages.的棘手之处在于，如果第二组中的任何服务器都收到了一条消息，那么第二组中的任何其他服务器都不会收到它。第一组中的所有服务器仍应能够使用此消息。
对于
浏览 2提问于2011-06-08得票数 1
回答已采纳
2回答
如果我有许多队列，并且每个队列都有一个唯一的ID，那么是否可以使用Hashtable of queues？我知道问这个问题听起来很奇怪，但我只是想知道是否有更好的优化方法。
很抱歉，我没有提供相关信息。我基本上是在存储由客户端id标识的消息队列。客户端将请求从服务器获取消息。在ack未到达服务器的情况下，消息仍保留在队列中，直到客户端再次尝试获取最旧的消息。其思想是在客户端无法确认时保留所有消息，并以FIFO方式检索所有消息。
浏览 0提问于2012-01-31得票数 2
回答已采纳
2回答
我有几个应用程序需要使用JMS相互通信。我将把它们描述为服务器和客户端。执行下列步骤：
客户端向服务器发送一个请求，记住消息ID。
服务器向给定的应答地址发送一个回复(并根据请求的消息ID设置相关ID )。
客户端使用关联ID将应答与请求匹配。
如果只有这两个人的话就行了。
当我们介绍(基于内容的)路由器时，将执行以下步骤：
客户端向路由器发送一个请求，记住消息ID。
路由器检查消息的内容并将消息转发给服务器。(转发消息ID更改时。)
服务器向给定的应答地址发送一个回复(并根据请求的消息ID设置相关ID )。
客户端与请求的答复不匹配，因为路由器更改了消息I
浏览 4提问于2013-01-08得票数 0
回答已采纳
2回答
关于JMS系统结构
、、、
我正在写一个服务器/客户端的游戏，一个典型的场景是这样的:一个客户端(clientA)向服务器发送一条消息，服务器中有一个MessageDrivenBean来处理这样的消息。在MDB完成其作业后，它将结果消息发送回另一个客户端(clientB)。
在我看来，这种通信只需要两个队列，一个用于输入，另一个用于输出。为每个连接创建新队列不是一个好主意，对吧？输入队列相对清晰，如果有更多的客户端同时发送消息，消息只是在队列中等待，而服务器中有更多的MDB实例，这应该不是一个大的性能问题。
但另一方面，我对输出队列不太清楚，我应该使用主题而不是队列吗？每个客户端都在监听输出队列，其中一个客户端获取新消息
浏览 2提问于2011-10-24得票数 1
回答已采纳
1回答
我一直在使用RabbitMQ，它支持对代理进行排队。
但是如何在ZeroMq中实现队列呢?当我尝试在Zeromq中实现客户端和服务器时，我不知道zeromq是如何实现队列的。因此，如果客户端非常快，而服务器很慢(可以通过调整服务器的休眠时间来实现)，则服务器似乎无法接收到客户端发送的所有消息。最初，我认为服务器可能会将客户端请求排在某个队列中，但从我的实验来看，它似乎不是这样工作的(消息丢失)！
任何建议..
谢谢你，阿伦
浏览 2提问于2012-05-28得票数 2
回答已采纳
1回答
考虑一个实时应用程序，其中web客户端与某个实体X进行持久连接。
我们在此可以选择的办法是：
连接到web服务器，然后web服务器将消息发送到消息队列。
在这种情况下，实体X等于某个web服务器，然后将该消息转发到消息队列。
|=Backend=
(client) ----------|-(web server)-----------(messageq)------> process message
| ^--backchannel connection
直接连接
浏览 7提问于2020-08-29得票数 0
回答已采纳
如何在AWS中创建类似于RabbitMQ中的“直接”交换:1消息-> N接收队列。
每个客户端应用程序连接到服务器并创建自己的队列，发布者发送一条消息到exchange (direct+routing密钥)并发送到所有N个队列，然后每个用户读取自己的队列，队列被清空。
浏览 12提问于2022-02-21得票数 -1
回答已采纳
2回答
我正在使用Camel开发一个客户机/服务器请求/回复系统。
客户机和服务器使用两个JMS队列进行通信:请求队列和响应队列。
服务器端有一个camel路由，它同时使用来自请求队列的JMS消息和处理消息。使用响应队列将响应发送回客户端。
客户端向JMS队列发送消息并等待响应。我有两个问题：
客户端实际上是其他应用程序将使用的库。我也想在客户端使用Camel，但不知道如何使用Camel作为“函数”--也就是说，在我有代码的某个时候，我需要“将这个对象发送到这个骆驼路线”。我该怎么做？
camel是否有一种使用两个队列处理请求/应答的标准方法？
非常感谢。
浏览 0提问于2014-10-05得票数 1
我已经在QTcpSockets和QThreads上为这个问题挣扎了几天了。
我有一个侦听端口并使用nextPendingConnection()创建新客户机的QTcpServer。所以现在客户端有了一个qtcpsocket，我可以用它来读写。
假设我有100个客户端连接到我的服务器。当它们中的一个想要向每个人广播消息时，我的主线程(我在其中使用nextPendingConnection()创建客户端)将不得不迭代100多个客户端并调用它们的套接字上的write方法。例如，如果10个用户同时广播，我将不得不进行1000次迭代，因此在我看来，在客户端(当用户接收消息时)会有一些延迟。
我想把所有的
浏览 0提问于2011-11-05得票数 1
回答已采纳
如何使用easynetq驱动程序在兔子mq中实现工作队列？
同时，在发布服务器和订阅服务器中都需要确认。
其想法是，一条消息将只由单个订阅者处理。这是默认行为还是消息扇从发布服务器向订阅服务器输出？
浏览 8提问于2016-05-17得票数 0
回答已采纳
11回答
我正在尝试从我的主机访问队列消息，同时尝试获取消息“访问消息队列系统被拒绝”。消息。不知道如何解决这个问题。我使用Windows7作为客户端系统，服务器是Windows2008 R2服务器
浏览 1提问于2012-03-26得票数 53
我使用ActiveMQ作为外部应用程序的消息服务器，但也用于内部消息。
如果我的应用程序停机时间太长，外部应用程序将完全关闭ActiveMq服务器。但是当我重新启动它时，它不能使用消息，因为它不能发送“内部”消息(我的路由是事务性的)。所以整个系统都被封锁了。
有没有办法为我的内部邮件预留一些存储空间？或者-可以限制某些队列的大小吗？
谢谢
浏览 5提问于2014-05-01得票数 3
我的问题是，我有两台服务器，一台正在运行messages，一台正在运行中的服务将从前者获得MQ消息。无论听起来多么简单，我都不能让后者连接到第一台服务器上的队列管理器。我尝试了以下操作：
从第二个服务器切换第一个服务器:它运行得很好。
Telnet来自第二台服务器的第一台服务器，使用用于连接第一台服务器上的MQ Manager的特定端口(1416)：它还可以找到
现在出现了奇怪的部分:我在第二台服务器上创建了一个队列管理器(在这台机器上也有一个MQ服务器)，与我想要连接的第一个服务器上的MQ管理器同名，然后我只能连接到这个队列，尽管在ChannelInfo中我指定了第一个服务器的I
浏览 1提问于2013-05-07得票数 1
我正在使用ActiveMQ和MQTT协议构建一个大型设备的系统，我在独立服务器上使用的模型包含两个应用程序，如下所示：
App1:企业应用程序从大量设备接收消息:设备每3分钟通过主题发布到服务器:设备？？MQTT协议？？> ActiveMQ？？-？？>用EJB订阅主题的Glassfish --> Oracle。
App2:来自Oracle的企业级应用程序扫描命令并发送到大量设备:每个设备订阅一个独特的主题，如: device.0000001，那么当服务器对设备数量较多的设备( <-- MQTT -- ActiveMQ <-- Openwire - Glas
浏览 0提问于2014-06-07得票数 1
3回答
我正在写一个小应用程序，我正在使用RabbitMQ发送/接收消息。一切都很好，但我在消息持久化方面有些困难。
我希望消息即使在服务器重新启动时也保留在队列中。我理解exchange和队列级别的持久性概念，并已将它们设置为true (相反，它们默认为true)。因此，当我重新启动RabbitMQ服务器时，exchange和队列保持不变，但队列中的消息被删除。
我正在使用EasyNetQ.IBus接口发送消息。
谢谢
浏览 7提问于2015-09-22得票数 6
我计划用RabbitMQ实现RPC模式。客户端将发送一条消息，请求服务器提供数据快照。服务器将通过响应队列将包含快照数据的许多消息发送回客户端。当收到最后一条消息时，客户端应该销毁响应队列。
我可以通过在消息或消息头中放置一些字段来手动实现此模式，但是是否有实现此模式的最佳实践方法，也许是一个指定的标头字段来发送最后一条消息？
浏览 2提问于2016-03-17得票数 0
回答已采纳
1回答
保护双工WCF MSMQ
、、、、
我正在构建一个系统，其中几个客户端使用双工MSMQ通过WCF连接到中央服务器(更新被发送到服务器，消息被定期推送到几个客户端)。
如何才能最好地保护此场景？双工WCF的本质有效地使每个客户端成为服务器。这是否意味着保护每个客户需要为verisign证书支付1200美元的每个渠道？
浏览 7提问于2011-10-27得票数 1
回答已采纳
1回答
我需要将一些“汽车”存储库(由不同的从服务器管理)同步到一个存储库(由一个主服务器管理)。
在这方面，我使用的是ActiveMQ。我已经定义了一个队列(master.car.queue)，主服务器将监听该队列，所有从机将在那里发布他们的汽车存储库(每5分钟)。
我有一个场景，其中一个从站在其存储库中有一辆汽车-因此它发布了相应的消息。几分钟后，这辆车被卖了-所以这个从车的存储库现在是空的-它应该如何通知主服务器？
我想到了以下几个选项：
1)为该用例创建另一个队列。
2)使用相同的master.car.queue -但发送新的消息类型或设置该消息的某个属性。
此用例的最佳实践是什么？
谢谢。
浏览 12提问于2017-02-22得票数 0
回答已采纳
注意事项:使用RabbitMQ .NET库
我的RabbitMQ上有一个名为FXTO.HK的主题交换，以及服务器将消息发布到此队列的FXTO.#绑定键。
在客户端，队列具有唯一和随机的名称，但使用相同的FXTO.#绑定键。
我们使用客户端库中的订阅类，它工作得很好:即。该消息由所有客户端同时接收。
但是，在RabbitMQ管理UI中，服务器队列(FXTO.HK)显示队列中的所有消息(它们没有从队列中删除)。
我在我的设置中做错什么了吗？何时从服务器队列中删除这些消息？
浏览 2提问于2011-11-15得票数 1
我有一个UI应用程序(显示流)，它将WebSocket连接到Spring微服务(多个JVM)，该服务将请求转发到一个上游服务器，并侦听来自上游服务器的JMS队列上的响应，然后响应消息必须返回到套接字。
我们面临的问题是，由于套接字是点对点的，而且Spring应用程序运行在多个实例上，所有这些实例都在侦听同一个JMS队列时，当在没有向上游发出请求的实例上接收消息时，我们无法将数据服务回WebSocket。
以下是基本流程：
WebSocket -> instance1, instance2, instance3 -> Data provider
Instance1向数据提供程序发出请
浏览 2提问于2021-02-13得票数 0
我想向WebSphere MQ中的队列发送一条消息。为此，我必须创建一个服务器连接通道定义，因为它是在
但是，我不知道在哪里输入这个创建通道的命令：
CRTMQMCHL CHLNAME(JAVA.CHANNEL) CHLTYPE(*SVRCN)
TRPTYPE(*TCP)
MQMNAME( QMGRNAME )
请在这个问题上帮助我。请告诉我客户端模式和绑定模式之间的区别。
浏览 3提问于2015-11-24得票数 2
4回答
我正在设计一个java服务器，这将用于交易债券。此服务器将充当客户端UI和分析服务器之间的中介。分析服务器是大脑，我的服务器将简单地与其交互(使用tcp套接字)，并将响应转发给客户端。
服务器预计可并发处理约500个客户端。而且它必须是可伸缩的和高效的，可以每秒处理大约500条消息。
客户端UI和分析服务器之间的消息流如下所示：
1. Client through the UI requests for price.
2. My server accepts the message, formats it and then asynchronously
sends to the anal
浏览 4提问于2009-08-13得票数 0
回答已采纳
2回答
erlang中的消息循环是如何工作的，它们在处理消息时是同步的吗？
据我所知，循环将从“接收”一条消息开始，然后执行一些操作并执行循环的另一次迭代。
所以必须是同步的？对吗？
如果多个客户端将消息发送到相同的消息循环，那么所有这些消息都将排队并依次执行，或者？
要并行处理多个消息，您必须在不同的进程中产生多个消息循环，对吧？
还是我误解了所有的一切？
浏览 2提问于2010-05-31得票数 7
回答已采纳
我有一个用于JMS消息传递的主/从AMQ代理设置。我有两个服务器，我想使用Apache Camel将它们设置为主/从耐用消费者。我们已经通过让两个服务器尝试使用相同的客户端ID进行连接来实现这一点。一个节点处理所有的工作，但如果它停止工作，另一个节点连接并立即恢复工作。这在一次只有一个使用者的情况下工作得很好，但它会在断开连接的服务器的日志文件中显示消息
ERROR org.apache.camel.component.jms.DefaultJmsMessageListenerContainer]
(Camel (spring-context) thread #0 - JmsConsume
浏览 11提问于2018-08-15得票数 0
1回答
发布到Redis频道的消息会在那里停留多长时间？另外，是否有一种方法可以配置最大值。每个通道的消息的生命周期？有没有办法控制通道的大小，或者只要Redis服务器有空闲的内存，通道就会继续存储消息？
浏览 2提问于2013-06-12得票数 0
回答已采纳
我试图在Microservice中的四种服务之间进行通信。每个服务都有服务器数据库。我用的是传奇模式。我的问题是，如果RabbitMQ崩溃或崩溃，或者无法返回，那么如果没有消息队列的帮助，我将如何回滚或还原数据库？
浏览 1提问于2022-01-20得票数 1
1回答
我最近开始学习可伸缩和企业计算机体系结构的细微差别，其中一个核心组件是消息队列。为了从任何编程范例中尽可能多地学习，我正在尝试实现我自己版本的消息队列服务。
到目前为止，我的初始设计是在线程套接字侦听器上运行的，但是为了防止同一消息被两个单独的处理节点下载两次，消息队列索引寄存器在启动读取时被锁定，并且在寄存器更新后解锁。因此，这就否定了线程化的需要，并意味着根据消息队列服务正在运行的服务器的处理速度，存在可伸缩系统大小的上限。
解决这个问题的方法是在多个服务器上运行消息队列服务，但这将增加同一条消息被下载两次的可能性。防止此类问题发生的唯一方法是包括一个撤销回调，该回调(在服务器，甚至是单个
浏览 0提问于2013-05-17得票数 26
我让syslog成功地将日志转发到上游服务器，如下所示：
$MainMsgQueyeType LinkedList
$MainMsgQueueSize 10000
$MainMsgQueusDiscardMark 8000
$MainMsgQueueDiscardSeverity 1
$MainMsgQueueSaveOnShutdown off
$MainMsgQueueTimeoutEnqueue 0
$ActionQueueType LinkedList # in memory queue
$ActionQueueFileName fwdRule1 # unique name
浏览 5提问于2013-10-30得票数 2
回答已采纳
2回答
我想在我的服务器之间建立一个基于事件的系统。例如，当包装我的数据库逻辑的服务器更改状态时，我希望它通知我的其他服务器。发布/订阅设计似乎是这方面的理想选择，我听说过关于ZeroRPC的好消息。
有些人提到过使用zerorpc流来实现发布/订阅，但是我并不清楚如何使用流来触发事件。
浏览 7提问于2012-08-16得票数 4
回答已采纳
1回答
我需要将消息接收到我的BigQuery表，我想知道使用这些消息的最佳方式是什么。我在AWS的Kafka服务器会生成AVRO消息，根据我所看到的，Dataflow需要接收JSON格式的消息。因此，我搜索并找到了一篇文章，解释了如何向PubSub接收消息，但在PubSub上，我只看到在这种体系结构中，他们在GCP上创建了一个Kafka来生成消息。我需要知道的是：
可以从外部的Kafka服务器在PubSub上接收AVRO消息，然后使用messages反序列化消息，将其发送到Dataflow，并最终将其发送到BigQuery表？
还是我需要创建一个Kafka并使用它来使用来自外部服务器
浏览 1提问于2021-04-27得票数 3
回答已采纳
1回答
使用Ruby库的v0.7.1和Ruby1.8.7，我试图向RabbitMQ服务器发送大量(数百万)短消息(约40字节)。我的程序的主循环(嗯，不是真正的循环，但仍然是)如下所示：
AMQP.start(:host => '1.2.3.4',
:username => 'foo',
:password => 'bar') do |connection|
channel = AMQP::Channel.new(connection)
exchange = channel.topic("
浏览 5提问于2011-08-17得票数 0
1回答
我开始从事Java套接字编程。我已经做了以下应用程序: 1.客户端向服务器发送消息，服务器收到消息后响应2.客户端和服务器像点对点聊天一样聊天
现在我想开发一个应用程序，当一个请求到达服务器时，它将为它生成一个线程。但现在的问题是，我无法识别这些线程。如果一个线程正在发送消息，那么服务器如何识别来自该客户端的消息，我必须将其转发到该客户端。两个客户端(实际上是它们的线程)如何通信？
我在上面搜索，我找到了synchronized关键字，我知道它的用法，我知道wait()，notify()和notifyAll()，但我仍然无法提供它们之间的通信。
如果我做错了什么，或者在跳到这个之前我需要了解一
浏览 0提问于2015-07-25得票数 1
技术栈
.Net 4.6.1
二郎18.3
语言: C# 6
NServiceBus 6
RabbitMQ 3.6.3
Windows 7
Context：我们试图在RabbitMQ传输上实现一个在NServiceBus中具有智能订阅的哑事件发布服务器。
所有感兴趣的接收者都订阅一个事件。
发布者将事件发布到事件通道。
所有订阅者都会收到事件的副本。
请注意，我没有说每种类型的订阅者都收到消息的副本。如果有多个服务实例正在运行，并且它们都具有对某个事件的活动订阅，则订阅服务的每个实例都应该得到消息的副本。
然而，NServiceBus的发
浏览 2提问于2017-01-10得票数 0
我有一个.NET TransactionScope，它需要包含一个MSSQL数据库和一个IBM队列。
我在完全管理模式下使用.NET 4.0 (VS2010)、SQL2008R2、MQServer6.0、MQ客户端7.0.1.9。所有组件都在不同的机器上运行。
根据我所发现的，下面的模式应该有效：
下面的代码描述了WebSphere MQ .NET应用程序如何使用.NET隐式事务编程来放置消息。
使用(TransactionScope作用域=新的TransactionScope ()) { Q.Put (putMsg，pmo)；scope.Complete ()；}
Q.close()；qM
浏览 2提问于2012-10-24得票数 3
回答已采纳
3回答
我想协调告诉服务器B从服务器A启动进程，然后在服务器A上运行导入脚本，当它完成后，我很难在这个场景中正确地使用SQS。
服务器A:主要专用服务器B:云处理服务器
服务器A通过SNS向SQS发送消息，表示“开始处理”
服务器B不断轮询SQS中的“开始进程”消息
服务器B在SQS上查找“开始进程”消息
服务器B运行"process.sh“文件
服务器B完成运行"process.sh“文件
服务器B从SQS中删除“开始进程”
服务器B通过SNS向SQS发送消息：“开始导入”
服务器轮询不断地轮询SQS中的“开始导入”消息
服务器A在SQS上查找“开
浏览 2提问于2013-03-13得票数 2
回答已采纳
我以前使用命令行的sendmail发送大量消息，并使用-odd标志延迟传递，这样程序就可以快速地将电子邮件放入队列，并在后台传递消息时返回给用户。这在手册页的DeliveryMode部分中有描述：
http://www.sendmail.org/~ca/email/man/sendmail.html
我移动到的新服务器正在使用exim和sendmail，它被别名为exim，并被-odd标志阻塞。有没有办法迫使exim对命令行中的消息执行延迟传递，并将其放入队列而不是立即尝试传递？
浏览 0提问于2013-03-24得票数 2
回答已采纳
1回答
我使用的是RabbitMQ管理码头图像。问题是在大约1周的正常运行时间之后，磁盘空间和内存几乎耗尽。我需要再次终止并重新启动它才能正常工作，但是这样做，队列中的所有现有消息都会丢失。
用于启动rabbitmq服务器的命令是：docker run --rm -it --hostname my-rabbit -p 15672:15672 -p 5672:5672 rabbitmq:3-management
我使用的是持久消息和持久队列。不是的。排队人数将在70人左右。每秒的连接可能从5到100不等。
我使用 npm模块使用Nodejs与RabbitMQ交互。
我做错了什么吗？或者，如果使用
浏览 5提问于2020-11-13得票数 0
5回答
我有多个队列，多个客户端将消息插入其中。
在服务器端，我有多个微服务访问队列并处理这些消息。每当服务运行时，我都希望锁定队列，这样其他服务就无法在该队列上工作。
这意味着，如果服务A正在处理来自队列X的消息，则在服务A完成消息处理之前，任何其他服务都不能处理来自该队列的消息。其他服务可以处理来自X以外任何队列的消息。
有人知道如何锁定队列并阻止其他人访问它吗？最好是其他服务将接收异常或其他东西，以便它们在不同的队列上再次尝试。
更新
另一种方法是将队列分配给服务，每当服务在队列上工作时，就不应该向队列分配其他服务，直到工作项被处理为止。这也是不容易实现的事情。
浏览 3提问于2016-04-18得票数 4
回答已采纳
3回答
同步消息可能与JMS/WMQ？
、、、、
假设有一个移动应用程序需要对来自服务器的某些数据进行同步请求/查询。请求将首先到达托管的JMS客户端，该客户机将在外部队列(来自合作伙伴)上发布消息/请求。现在这里的情况还不清楚。如何以同步的方式从合作伙伴那里得到响应。
合作伙伴是否应该公开单独的队列供我订阅，然后阻止移动请求，直到从该单独的队列获得响应消息？
JMS或专有的WebSphere MQ接口是否支持同步消息传递？
用消息传递实现它的其他方法是什么？
谢谢
浏览 24提问于2011-02-17得票数 4
回答已采纳
1回答
基于的As使用
Service提供自动有害消息检测。如果接收来自队列的消息的事务回滚5次，自动有害消息检测将队列状态设置为OFF。此特性为应用程序无法以编程方式检测到的灾难性故障提供了保护。
我有一个windows服务应用程序，它轮询SB队列并将它们发送到web服务端点。因为我应该处理任何“服务器关机”问题，所以我将“队列项接收”和“队列项发送”方法包含到相同的事务中。在第一个异常(HttpRequestException)上，我开始对服务器进行预定义超时，然后继续/关闭程序。
但是，回滚5次是一个问题，我了解到，无论5个连续回滚之间的时间间隔如何，它总是会在全局范围内增加回滚计数，因
浏览 1提问于2017-08-15得票数 1
回答已采纳
1回答
我有一个azure函数，它通过将新消息添加到队列中来触发。它应该从FTP服务器下载一个文件，该文件的名称是我推送到队列中的消息的一部分。
在某些情况下，托管文件的服务器可能会变得无法访问，当然，我会得到异常。
我想知道队列在这些情况下是如何工作的？它会弹出消息并留下它吗？或者它会保留它并一次又一次地调用函数，直到任务完成而没有任何异常？
浏览 0提问于2019-11-19得票数 0
我正在尝试开发基于非阻塞NIO消息的自己的通信库。我已经阅读了1000篇关于它的教程和书中的章节，我认为到最后，我有一些东西可以在几乎没有同时连接的情况下工作。但是，当服务器端有许多连接共存时，我会遇到一些问题。
我有典型的选择器实现与4种私有方法:接受，finishConnect，读和写。我的问题在于前两个问题:接受和finishConnect。
当客户端打开一个新套接字，一个可接受的键唤醒选择器时，将执行以下代码。
private void accept(SelectionKey key) {
try {
ServerSocketChannel ssc = (Ser
浏览 2提问于2015-10-11得票数 1
回答已采纳
2回答
不是MSMQ或WCF的专家，我读了很多关于它的文章，它听起来和看起来都很棒。我正在尝试开发一些东西，最终但首先是一些理论，它需要是健壮和持久的。
我猜MSMQ将被托管在一个单独的服务器上。
将有2个WCF服务。一个用于传入消息，另一个用于传出消息(接收消息，进行一些内部处理/验证，然后将其放入传出消息队列中，或者可能发送电子邮件/文本消息/任何内容)
据我所知，通过正确的配置，我们可以让系统具有事务性(不会丢失任何消息)，并且可以只发送一次，因此不会有重复消息的机会。
应用程序/服务将是多线程的，以处理数以百计的消息。
但是在消息处理期间或整个服务生命周期中，如果服务器崩溃怎么办？如果服务器重
浏览 2提问于2012-04-20得票数 2
回答已采纳
当一条新消息到达队列管理器时，它将自动触发我的控制台应用程序。然后，它将获取该消息并将消息写入文件中。我已经完成了这部分。但我在触发消息队列方面有问题
下面是我配置消息队列的方式
我创建了两个队列，一个是LocalQueue，另一个是InitQueue，也就是SYSTEM.DEFAULT.INITIATION.QUEUE。
并在我的LocalQueue中设置“触发器”属性
然后创建触发器监视器
在流程定义对象中，我设置了控制台应用程序路径。
因此，我的问题是，它不像预期的那样工作，我检查了我的客户机C:\Program (x86)\IBM\WebSphe
浏览 6提问于2014-11-10得票数 2
回答已采纳
3回答
我需要写一种代理服务器，我的设计有点像这样:1.Socket服务器(使用Windows事件选择模型)。程序有一个监听线程监听网络事件。
客户端列表(当前按socketid_list编制索引)。3.套接字服务器接受新的连接，然后为每个客户端创建新的线程。新线程创建到终端目标服务器的套接字连接(需要持久连接)。
我已经编写了套接字服务器，它工作得很好。我的问题是，当新消息从客户端传入时，我如何将此消息传递到相关线程(以便消息可以发送到目标服务器)。
在我的服务器中，我从客户端消息中获取最终目标服务器的地址。我可以从客户端套接字列表中查找客户端套接字。但是我该如何将消息发送到正确的线程呢？
到目前为
浏览 0提问于2011-09-01得票数 2
回答已采纳
2回答
C#即时消息
、、、
我正在用C#编写一个即时消息程序(仅供学习)。
我只想知道我的方式是对还是错。
我创建了一个客户机类，其中包含一个NetworkStream和读/写函数。
服务器为每个客户端创建一个新线程，该线程侦听任何新消息。
还有更好的办法吗？
浏览 0提问于2010-02-19得票数 0
回答已采纳
2回答
在谷歌搜索了whatsapp这样的聊天信使如何发送/接收消息后，我偶然发现他们使用了基于队列的消息传递系统。我只是想弄清楚这个特性的高级设计是什么？
HLD对地雷的理解:-说朋友1和朋友2在线。朋友1已经建立到web服务器1的HTTP连接，朋友2已经建立到web服务器2的HTTP连接，朋友1将消息发送给朋友2。
现在，一旦消息到达web服务器1，我需要将消息传送到web服务器2，以便通过已经建立的web连接将消息推送回朋友2。
我相信，这里可以使用分布式自定义java队列将消息从一个服务器传播到另一个服务器。一旦消息到达一台服务器，它就会将其推送到具有消息内容、fromUserId、toUse
浏览 10提问于2017-01-28得票数 7
回答已采纳
2回答
是否有可能使用联邦或铲子来镜像一个服务器和另一个服务器上的交换和队列的创建？
我看到的使用铲子和联邦的所有示例都使用服务器上已经存在的交换和队列。我想做的是在服务器A上创建一个交换，并在服务器B上重新创建一个联邦或铲子，然后开始向它发送消息。
如果在不使用集群的情况下，联合或铲子无法实现这一点，那么这两个服务器之间的连接是不一致的，所以集群是不可能的。
我正在windows上运行RabbitMQ。
浏览 1提问于2014-04-08得票数 8
回答已采纳
1回答
我希望使用MSMQ创建以下拓扑：
服务器A中的服务将消息写入本地队列
服务器A中的本地队列是服务器B中另一个队列的中介
这意味着当服务器A中的服务将消息写入服务器A中的队列时，此队列立即将此消息传输到服务器B中的队列。如果由于任何原因到服务器B的连接关闭，则服务器A中的队列将聚合这些消息，直到连接恢复为止。
MSMQ是否支持此拓扑？
浏览 2提问于2015-03-03得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
