为什么Google pubsub java8客户端在确认后仍会收到重复的消息？
我们正在使用google-cloud-pubsub(0.24.0-beta)拉客户机来阅读来自订阅者的消息，并在其中看到高比率的重复。谷歌文档说，很少会出现重复，但在我们的案例中，我们看到80%的消息在确认后仍然重复。
最奇怪的是，即使我们使用consumer.ack（）立即在receiver中确认消息，重复仍然发生。有人知道怎么处理这个吗。
共有1个答案
大量消息重复可能是流控制设置设置过高或过低的结果。如果您的流控制设置太高，即允许太多消息在同一时间对您的客户端未完成，那么可能ACK设置得太晚。如果是这个原因，您可能会看到您的机器的CPU在100%或接近100%。在这种情况下，请尝试将未处理消息或字节数的最大值设置为较低的数字。
也可能是流控制设置设置得太低。有些消息在传递到MessageReceiver之前会在客户端中进行缓冲，特别是在您受流控制的情况下。在这种情况下，消息在传递之前可能会在客户端中缓冲太多时间。此状态下的邮件存在一个问题，该问题正在未完成的PR中修复。在这种情况下，您可以增加您的最大未完成字节或消息（直到您的订阅服务器能够实际处理的任何内容），也可以尝试将AckExpirationPadding设置为比默认500ms更大的值。
还值得检查您的发布服务器，看看它是否意外地多次发布消息。如果是这种情况，您可能会看到消息的内容是相同的，但它们不是由Google Cloud Pub/Sub本身生成的重复消息。
-
这是获取请求： 这是后端代码： 错误： CORS策略阻止了从源“http://localhost:3000”在“http://localhost:3001/”获取的访问：请求的资源上不存在“访问-控制-允许-起源”标头。如果不透明响应满足您的需求，请将请求的模式设置为“no-cors”以在禁用CORS的情况下获取资源。
-
1.场景描述：设备向Netty服务器发送数据（大约##20ms间隔##)，Netty服务器向客户端转发消息##立即##（IOS或Android）。2.关联业务代码CTX.WriteAndFlush（msg） 3.发出网络服务器可以及时接收设备数据，网络服务器也可以及时将数据写入套接字缓冲区。但Netty客户端收到消息时延！！！（如5s时延） 4.服务器带宽配置入站100M/bps位/秒。出站5M/
-
这里是完整的代码 我看到write和send函数返回字节数的和，而这里返回0，并且客户端似乎运行正常，这让我很困惑。
-
我有： hornetq-2.2.14-final独立服务器 C1使用jmstemboard在CLIENT_ACKNOWLEDGE模式下发送消息： 因此指挥与控制应手动确认消息： 我的问题： 当客户端C2收到该消息但在确认之前崩溃时，消息会发生什么？ 是否有超时机制？如果是，确认的默认超时是什么？我如何修改它？
-
如果在ActiveMQ中创建了一个队列，该队列具有一个生产者（即客户端确认模式）和一个侦听器，在成功处理消息后，其onMessage方法中仅对其进行确认。假设存在异常，并且消息未被确认，因此仍在队列中。是否会再次发送给消费者？或者这些信息会发生什么？
-
问题内容： 为什么在代码的指定位置出现ConcurrentModificationException？我无法弄清楚自己在做什么错… 正在使用该方法在列表中找到分钟，将其删除并返回其值 问题答案： 一旦修改了从其获得的Collection，则不应认为Iterator可用。（对于java.util.concurrent。*集合类，放宽了此限制。） 您首先要获得一个Iterator ，然后进行修改。修改