设置消息超时
消息超时是指在消息队列中，当消费者获取消息后，如果在一定时间内没有完成处理并确认消费，系统将认为该消息已超时，会进行相应的处理。
消息超时的设置有助于处理消费者无法正常处理消息的情况，例如消费者处理能力不足、网络故障等问题。通过设置消息超时时间，可以确保消息能够在一定时间内被及时处理，避免消息积压或丢失。
分类：
- 消息队列超时：针对消息队列中的消息设置超时时间，用于判断消息是否已过期。
- 操作超时：指在处理特定操作时设置超时时间，例如数据库操作、网络请求等。
优势：
- 系统稳定性：通过设置消息超时，可以避免因消息处理超时而导致的系统阻塞或崩溃，提高系统的稳定性。
- 异常处理：当消费者无法正常处理消息时，超时机制可以帮助系统及时发现问题，并进行相应的处理，例如重新投递消息、记录异常日志等。
- 提高吞吐量：设置合理的超时时间可以帮助系统快速释放资源，提高消息队列的吞吐量。
应用场景：
- 异步任务处理：在任务执行过程中，通过设置超时时间，可以判断任务是否超时，并根据需要进行重试、放弃或记录异常。
- 订单处理：在订单系统中，可以通过设置超时时间，避免订单长时间处于未处理状态，及时进行后续处理，如超时自动取消订单、提醒相关人员等。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云云函数 SCF：https://cloud.tencent.com/product/scf
- 腾讯云云数据库 TDSQL：https://cloud.tencent.com/product/tdsql
- 腾讯云云服务器 CVM：https://cloud.tencent.com/product/cvm
- 腾讯云人工智能：https://cloud.tencent.com/product/ai
相关·内容
1回答
Python套接字超时
、、、
我当前正在使用socket.recv通过我的客户端接收来自服务器的消息。如果5秒内没有收到任何消息，有没有办法显示自定义错误并关闭连接+客户端？
浏览 0提问于2015-09-11得票数 0
我有一个带有小消息的weblogic持久队列。但是，我的MDB逻辑至少需要2分钟来处理消息。我正在用队列中的一条消息测试我的设置，问题是MDB仍然在处理消息，就在一分钟后，我可以看到消息被重新传递，而另一个mdb层正在处理它。第二个失败了，因为我的桌子上有一个独特的条件。第一个MDB仍在继续，并在2分钟后成功完成。
我尝试在将消息发送到队列时同时使用CLIENT_ACKNOWLEDGE和DUPS_OK_ACKNOWLEDGE，而且我可以看到，即使在MDB开始处理它之后，消息仍然保留在持久存储(oracle表)中，而且由于需要2分钟，它在一分钟后重新发送，这并不理想。只有在第一个MDB成功完成之
浏览 1提问于2014-02-19得票数 0
回答已采纳
1回答
我有一个现有的应用程序，它通过队列传输将消息从一个进程发送到另一个进程。我想通过在处理消息时提供延迟来改变消息的处理方式，并让队列更多地充当优先级队列，其中消息应该首先在队列顶部执行操作。
即：
在时间0，消息A被发送到队列，延迟15分钟。5分钟后，消息B被发送到队列，延迟10分钟。处理队列的服务随后崩溃，并且在15分钟内不会重启。当队列再次开始处理时，消息B将位于顶部，随后是消息A。
在C# / MSMQ / .NET生态系统中有这样的东西吗？
浏览 6提问于2012-05-27得票数 1
回答已采纳
我有一个业务流程，它会被两种类型的消息中的一种激活，这些消息都是以并行的形式传入的。消息通过ID和状态进行关联，然后执行业务流程的其余部分(将消息合并为1)。
我想设计一种方法，以防止脱水的情况下，管弦乐发生时，其中一条信息没有通过。因此，基本上，1条消息传入，而另一条消息没有，编排实例在等待第二条消息时会脱水。
我已经做了一系列的搜索，并找到了一些不错的方法，如果这是串行车队，但它不是，并没有保证消息的顺序。
例如，在串行车队方面非常有用，但仍然不能满足我的要求。
我尝试使用侦听形状，将每个消息放在自己的分支上，在第三个分支上使用延迟，但了解到如果您使用侦听激活，所有分支都必须激活
浏览 1提问于2014-10-06得票数 2
回答已采纳
假设您有一个应用程序A和一个应用程序B，它们使用ActiveMQ队列进行通信。通信如下所示。
A使用队列名com.example.requestQueue向应用程序B发送请求消息
B使用来自队列名称com.example.requestQueue的消息请求。
B需要一些时间来处理消息请求，然后使用响应队列名com.example.responseQueue将一个响应发送回B
从com.example.responseQueue队列中消耗响应消息，并完成
如果应用程序B总是在应答，那么就没有问题，但是如果由于某种原因，应用程序B消耗了来自请求队列com.example.r
浏览 2提问于2021-06-28得票数 0
回答已采纳
我正试着在VS2010中调试一条消息，这条消息是从我的事务性MSMQ发送过来的。
我在队列中有1条消息。
问题是，如果我放置了一个调试断点，并将其保留了几秒钟，然后转到下一行，我会看到消息再次被重新分派到应用程序，导致帧再次跳回到应用程序的起始/入口点。
我怎么才能让它和1消息一起工作呢？(队列中只有一条消息，所以我的问题是如何防止它多次调度)
非常感谢，
浏览 3提问于2012-09-13得票数 2
回答已采纳
1回答
我正在尝试实现以下目标:一个客户端代理实例(保持打开)，由多个线程使用可靠的会话访问。到目前为止，我管理的是A)与客户端代理的可靠会话(该代理是根据调用创建和处理的)，或者B)我的目标是什么，但没有可靠的会话。
但是，当我在绑定上启用可靠的会话时，将显示以下行为：
客户端
在应用程序启动时，一切看起来都很好，直到WCF会话中有大约18条消息。首先引发proxy.InnerChannel.Faulted事件，然后在代理上调用方法时捕获异常。例外情况是一个System.TimeoutException，带有消息：
“请求通道在00:00:59.9062512之后等待回复时超时。增加传递给请求调用的
浏览 0提问于2009-07-17得票数 19
我们有一个C#服务器，它使用套接字接收TCP消息。通常的流程是调用socket.Accept()，使用socket.BeginReceive()和socket.EndReceive()来接收消息，然后使用socket.Send()发送响应。这个很好用。
但是，当一次收到太多请求时，我们希望立即拒绝溢出，这样我们就不会淹没服务器。在Accept()之后直接关闭套接字是很容易的；但这不允许我们向客户端发送一条有意义的“太忙”消息。
我想做的只是简单地调用Accept()，然后调用Send()，而不接收传入的消息。我尝试过这样做，服务器声称发送我的数据，但是我的客户端只收到一个空的响应。我尝试过使用
浏览 3提问于2015-03-25得票数 3
回答已采纳
我正在学习AWS课程，并试图了解AWS SQS (简单队列服务)是如何工作的。我有点被能见度超时弄糊涂了。我知道可见性超时是要在其中处理的消息的持续时间。
这就是模型
正如您在图表中看到的，使用者将提取消息或消息，并在可见性超时内处理消息或消息。如果在可见性超时内没有处理消息或消息，则使用者将不会接收或处理消息或消息，并且消息将留在队列中。
以下是我的困惑：
可见性超时对一次轮询中的所有消息有效吗？还是将超时单独应用于每条消息？例如，消费者一次轮询5条消息。如果其中两个在超时时间内未被处理，其中两个将被发送回队列，其余三个将被删除。或者，所有5条消息都是在超时内处理的，如果其中任
浏览 7提问于2020-01-28得票数 4
回答已采纳
1回答
最近，我不得不开发一个从SQL Server2008 R2获取大量数据的系统。然后需要使用这些数据创建HL7消息，并将这些HL7消息发送到另一个应用程序。我还需要在循环中获取数据并创建HL7消息。我面临的问题是，在运行application.How 1或2分钟后连接超时，我能防止这个问题吗？我该怎么办？
浏览 1提问于2015-12-21得票数 0
1回答
我有以下代码：
public interface RmiServer extends Remote{
public String getMessage()throws RemoteException;
}
public class DefaultRmiServer implements RmiServer{
private LinkedBlockingQueue<String> queue;
@Override
public String getMessage()throws RemoteException{
return queue.take();
浏览 6提问于2016-07-25得票数 1
回答已采纳
我正在尝试从一个使用Python作为编程语言的Lambda函数查询我的Amazon海王星数据库。 我的问题是 g.V('1').out().toList() 10秒后，我收到错误消息："Task timed out After 10.01秒“ 我尝试将evaluationTimeout更改为更大的值，但它不起作用 g.with_('evaluationTimeout',100000000000).V('1').out().toList() 使用上面的查询，我仍然得到错误"Task timed out after 10.01秒“
浏览 48提问于2021-09-14得票数 0
2回答
我有REST服务，它使用队列中的消息。我想按需消费消息-当rest服务被调用时，给我队列中所有可用的消息。
我在Spring中使用ActiveMQ。下面是我用来从队列中获取消息的代码。当我第一次访问服务时，我得到了队列中所有可用的消息，但如果我进一步发布更多的消息，即使我没有访问服务，消息也会被订阅。这可能是什么原因呢？
while (true) {
try {
message = jmsTemplate.receive("TestQ");
if (message instanceof TextMessage) {
浏览 3提问于2014-03-06得票数 0
1回答
我注意到，订阅JMS主题的进程在一段时间内没有消息发布到该主题后，会停止接收发布到该主题的消息(这一次我不能精确地量化，但假设是一分钟)。我使用JBoss ApplicationServerV4.2来管理主题。
你知道为什么会这样吗，以及如何确保我的订阅者即使在他们的主题上没有任何帖子发布了几天后，仍然能够收到消息？
浏览 0提问于2013-03-15得票数 1
回答已采纳
我有一个AJAX函数来检查新消息，然后将新消息添加到#message。但是，我的问题是，这个函数每隔20秒触发一次，但每当您单击立即触发该函数的刷新按钮时，它就会出错。下面是我的AJAX函数：
function ajaxMail() {
var message_id = $('.line:first').attr('id');
jQuery.ajax({ //new mail
type: 'get',
dataType: 'text',
url: "/empl
浏览 0提问于2011-10-30得票数 1
回答已采纳
2回答
我有一条错误消息，当一个值出错时，它会显示出来。使用3秒的setTimeout，消息就会淡出。问题是，当消息第一次显示并等待3秒时，用户再次单击submit，事件将再次触发。第一条消息淡入淡出，第二条消息也淡入淡出。show message的代码如下：
function showMSG(txt,type){
$('.msg .text').html(txt);
$('.msg').fadeIn(300);
$('.msg img').attr({'src':'images/'+(type?'ms
浏览 0提问于2010-12-05得票数 1
回答已采纳
我正在使用Camel流，它使用Netty套接字使用者来接收来自客户端程序的消息(这超出了我的控制范围)。客户端应该打开一个套接字，发送给我们一条消息，然后关闭套接字，但是我们已经看到了这样的情况，即Camel正在将文本流“分割”成两个部分，并试图分别处理它们。
所以我想弄清楚，既然您可以对多个Camel消息重复使用相同的套接字，但是TCP套接字没有内置的“框架”概念或消息分隔符的标准，那么Camel如何决定是否已经接收到完整的消息并准备进行处理？我还没有在Netty ()中找到有文档记录的答案，尽管我可能遗漏了一些东西。
通过使用测试脚本，似乎有一个答案是"Camel假设消息是完整的，
浏览 5提问于2022-02-22得票数 0
使用1.6SDK(版本2011-08-18)，您可以更改队列消息的不可见超时。然而，阅读REST文档，似乎表明您必须回发消息。我知道该操作的目的是更新整个消息(包括不可见超时)，但我只想更改不可见超时，而不必重新发送整个消息。这个是可能的吗？
谢谢，埃里克
浏览 0提问于2012-02-04得票数 4
回答已采纳
1回答
的Gateway元素具有“默认回复超时”属性，但无法根据消息本身的数据设置超时值。我可以为每个可能的超时值创建一个网关，然后在运行时为该消息选择一个适当的网关，但这显然是一个棘手的解决方法。
版本4.2向TCPOutboundGateway添加了一个“远程超时表达式”属性，但该更改并没有使GatewayProxyFactoryBean生效。
话虽如此，是否有一种方法可以配置特定于消息的超时？如果不是，“远程超时表达式”属性是否计划在某个时候移植到GatewayProxyFactoryBean？
谢谢你的帮助！
浏览 1提问于2016-05-16得票数 0
回答已采纳
1回答
在喷雾中，对于分块的响应，我们可以使用发送分块的消息，如
peer ! MessageChunk(buffer).withAck(MyAck(k))
我们可以得到确认消息传递到操作系统网络层的ack消息。我们有类似暂停的东西吗？
浏览 6提问于2015-03-09得票数 0
1回答
我正在尝试创建一个基于Azure Storage Queue的弹性系统。
我有两个不同的Azure区域的工作人员正在处理来自同一个队列的消息。在第二个区域的工作人员开始处理消息之前，我想在队列之前优先处理来自同一个区域的工作人员。
我的想法是使用可见性超时功能，它将随工作人员类型的不同而变化。有可能吗？
浏览 1提问于2019-10-27得票数 0
我已经将配置为使用来自队列的消息的ActiveMQ使用者。让我们称之为"Test.Queue“--我在4台不同的机器上部署了这段代码，所有机器都被配置到同一个ActiveMQ实例中，以处理来自同一个"Test.Queue”队列的消息。
当所有4台机器启动并运行时，我将最大使用者大小设置为20，我看到队列中的消费者数为80 (4 * max使用者大小= 80)。
当生成并发送到队列的消息越来越高时，一切都很好。
当有1000条消息时，在80个使用者中，假设其中一个被卡住了，就会冻结Active MQ以停止向其他使用者发送消息。
所有的消息都永远卡在ActiveMQ中。
由于我有4
浏览 4提问于2012-08-21得票数 6
回答已采纳
下面是我使用AWS从C#发送SQS消息的基本代码。如何给消息一个与队列默认值不同的超时？
public async Task PostMessage(Uri queueUrl, string body)
{
var request = new SendMessageRequest()
{
MessageBody = body,
QueueUrl = queueUrl.ToString(),
浏览 1提问于2014-09-25得票数 1
回答已采纳
从的文档中可以看出：
否则，系统可能会等到至少有一条消息可用时(持续一定的时间)，而不是不返回任何消息。
有任何方法来配置这个“(在有限的时间内)”吗？我正在使用。
浏览 9提问于2022-06-29得票数 0
给定接收请求并向消息用户使用外部消息传递服务的应用程序。请求的数量通常是非线性的，有时会向服务的消息用户发送大量的请求。外部消息传递服务允许吞吐量(例如x/秒)。
使用ElasticBean秸秆工作人员和SQS，是否有可能对这些消息的处理方式应用一些速率限制？
浏览 2提问于2016-04-21得票数 8
我有一个远程机器，它有一个私有队列，服务器将这些消息发送到远程队列。这很好用。该问题是，当远程计算机未连接到网络或关闭时，消息将保存在服务器的传出队列中，然后在远程计算机联机时传递。现在，我的要求是，如果消息没有传递，服务器应该知道。在当前的情况下，没有异常被抛出，因为它保存在传出队列中。
现在我想到了三件事。
传出队列不应该保存消息。应该从远程机器返回一些确认。i应该通过队列url直接发布消息，作为它在IIS.下托管的消息。
我想提出解决方案3，但没有找到任何关于这一主题的资源。
浏览 0提问于2011-04-07得票数 0
我正在使用NSB 4.4.2，我希望在我的传奇中有一些类似心跳的东西来显示处理统计数据。当我请求超时时，它会发送到sagas输入队列。如果在此超时消息之前有许多消息，则可能不会在特定时间触发IHandleTimeouts。是虫子吗？或者如何使用单独的队列来处理超时消息？
谢谢
浏览 3提问于2014-07-02得票数 0
回答已采纳
对不起，如果我的问题不太清楚，很难解释我的问题。
因此，我第一次使用CXF框架。我在网上找到了一个解决方案，但没有成功。让我们解释一下用例。
我尝试编写一个Web服务(在服务器模式下)来接收SOAP消息、处理处理和回答。为此，我在WSDL优先方法中使用CXF。
我的实现似乎运行良好，我通过已实现的类接收SOAP消息，注释为“@webservice”.处理此请求并返回一个答复。我的问题位于处理端，有些东西，取决于SOAP消息，它的cna非常长，在这种情况下，CXF处理超时。因此，我想配置“超时值”，使我能够进行长时间的处理。
EndpointImpl jaxWsEndpoint = (E
浏览 23提问于2016-06-24得票数 0
1回答
我正在尝试在数据库querys...so上实现一个超时，如果一个操作运行了太长时间，我需要取消查询并向asp.net页面返回一个超时消息...
下面是我用于超时portion....problem的代码，我有时会从查询中获得部分结果集……
RunSearch search = new RunSearch(GetSearchResults);
Thread searchThread = new Thread(delegate() {
dsRes = search.Invoke(ProcessingID,
objSqlConnection,SearchStartTime); });
sea
浏览 3提问于2011-02-05得票数 1
回答已采纳
我的数据报套接字没有抛出SocketTimeout，尽管设置了它，但我不确定如何解决这个问题。代码如下。问题是，如果它在此套接字连接上没有接收到任何消息，它将在第一次运行时超时。但是，它成功地接收了几次消息，稍后调用.receive时不会超时。
DatagramSocket serverSocket = new DatagramSocket(serverSyncPort);
serverSocket.setSoTimeout(200);
while(true)
{
receiveData = new byte[1024];
receivePacket = ne
浏览 4提问于2012-12-12得票数 0
来自文档：
连接字符串："...;Timeout=1200"；
代码：
public IDbConnection Connection
{
get
{
return new NpgsqlConnection() { ConnectionString = this.config.GetConnectionString("PostgresConn") };
}
}
..。
using (IDbConnection dbConnection = Connection)
{
浏览 8提问于2022-06-07得票数 0
回答已采纳
我正在开发asp.net MVC3应用程序。我正面临一个与会话到期相关的问题。当我登录后，网站处于非活动状态达10-15分钟，我尝试单击任何链接，结果显示对象引用为空错误。我希望当会话到期时，点击任何链接，我应该被重定向到登录页面与错误消息，会话到期，或弹出与相同的消息。如何在asp.net MVC3中实现它。
你好，阿西夫·哈米德
浏览 1提问于2011-11-03得票数 1
我正在使用Weblogic 12c(12.1.3)应用服务器来运行我的应用程序。我已经在Weblogic中将完整的消息超时配置为30秒，但是当Qualys扫描在此服务器上运行时，它仍然可以通过发送一个传输速率非常慢的请求来保持连接打开超过30秒(在我的例子中，该连接在300秒后仍处于打开状态)。
这意味着完整的消息超时设置无法在服务器上工作，否则连接将在等待最多30秒后终止。还有其他配置吗?还是我漏掉了什么东西？
我遵循了Oracle的建议，如下文所示：
https://docs.oracle.com/cd/E24329_01/web.1211/e 24390/wls_tuning.htm#P
浏览 0提问于2017-08-08得票数 1
2回答
这是我的php代码。我想在10秒内运行它，如果它在10秒内运行，则打印$content，否则打印错误消息。另外，如果$content为null，则打印错误消息，如果不为null，则打印$content。
<?php
$content=file_get_contents("http://anyurl/test1.php");
if($content=="") {
echo "there is error";
} else {
echo $content;
}
?>
浏览 6提问于2014-08-16得票数 0
1回答
我有一个小应用程序可以使用来自RabbitMQ的消息。
当前，它在wait (1)循环中调用"Dequeue“，然后在那里等待消息，然后处理消息。
因此，我认为阻塞调用"Dequeue“是个好主意，或者立即的DequeueNoWait(没有立即返回)不会更好，甚至可能是带有超时的"Dequeue”。当然，迭代时会有更多的内容。
谢谢
浏览 1提问于2016-08-19得票数 0
回答已采纳
1回答
我有一个ServerSocket等待接受连接。在接收到另一个线程上的某个事件时，我关闭套接字，使它不再等待连接。我收到一个带有“套接字关闭”消息的java.net.SocketException。问题是，如何识别“套接字关闭”异常。我可以使用异常消息来完成这个任务，但我觉得这不是我应该如何处理异常。
我查阅了文档：
SocketException类有许多子类，但是我找不到任何引用“套接字关闭”的东西。可以使用异常消息来标识它吗？这条信息会不会改变，也许在另一个平台上或者别的什么？
下面是一些代码：
try {
// Wait for connection,
connection
浏览 0提问于2018-05-06得票数 0
2回答
按需调度
、、、
我有一个守护进程，它不断地为消息汇集一个AWS SQS队列，一旦它接收到消息，我需要一直增加可见性超时，直到消息被处理为止。
我想设置一个“按需调度器”，它每隔大约X分钟增加消息的可见性超时时间，然后在消息处理后停止调度程序。
我尝试过使用Scheduler ()，但这并不能满足我的需求，因为它不是按需运行的。
这是在一个拥有庞大舰队的分布式系统上完成的。
一条消息可能需要10个小时才能完全处理。
我们不能将队列的默认可见性超时设置为高数量(由于其他原因)。
我只想知道是否有一个好的库，我可以利用它来做这件事吗？谢谢你的帮助！
浏览 0提问于2016-08-11得票数 0
回答已采纳
1回答
在我们的解决方案中(纯消息传递，没有编排)，我们使用MLLP适配器和HL7v2x管道在请求响应接收位置接收消息。接收管道生成并发布响应消息，由于提升的属性，响应消息将通过请求/响应接收端口的发送管道路由到客户端。
然后，我们有一个双向发送端口，它订阅接收到的消息，使用一个映射来翻译消息，并发送到同一个BizTalk机器上的请求响应WCF接收端口。这听起来很奇怪，但是我们有通过web服务发送数据的客户端，也有通过HL7v2 MLLP发送数据的客户端，这就是为什么我们要这样做的原因。
WCF请求响应接收端口还通过发布消息并提升EpmRRCorrelationToken、CorrelationTok
浏览 3提问于2015-05-25得票数 2
1回答
由于某些原因，当我使用异步请求时，html5验证消息不会显示。
在这里您可以看到一个示例。
setTimeout(function() {
...
//this is not working
target.setCustomValidity('failed!');
...
}, 1000);
未选中复选框时，一切按预期工作，但选中复选框时，消息不可见。
有人能解释一下应该怎么做吗？
浏览 2提问于2013-03-18得票数 11
回答已采纳
setTimeout(function () { showToastMessage("Guest added successfully test2").fadeOut(4000);});
我想把这条消息显示到5秒。但我不知道怎么设置显示时间。我知道如何设置延迟时间。我曾经使用过.fade Out方法，但它不起作用。我仍然有麻烦。帮帮我
我想把这条消息显示到5秒。但我不知道怎么设置显示时间。我知道如何设置延迟时间。我曾经使用过.fade Out方法，但它不起作用。我仍然有麻烦。帮帮我
浏览 2提问于2013-10-10得票数 1
回答已采纳
我正试图在我的UDP停止等待中实现TIMEOUT功能。也就是说，我使我的接收者不是故意发送ACK，而是期望发送者在TIMEOUT之后重新发送。
但是，正如文档所述：
如果套接字上没有可用的消息，接收调用将等待消息到达，除非套接字是非阻塞的。
所以我的发送方和接收方都被困在了sendto()和recvfrom()上。他们都被绞死了！THere是一种让代码继续运行以实现TIMEOUT的方法。
我该怎么做？
浏览 2提问于2013-10-28得票数 2
回答已采纳
1回答
我是在玩游戏。服务器和客户端都以高速率通过非阻塞的UDP交换消息.
(也许这里很奇怪)遗留代码还使用将超时值设置为select()的0，这意味着select()不阻塞。select()在一个永久的while循环中。在select()返回一个大于0的数字时，下面的代码将通过recvfrom()接收消息。如果它返回0，下面的代码不会尝试接收。
从打印出的信息，我看到select()有时返回1 (大于0)。我感到困惑的是，既然超时设置为0，那么select()如何有时间检查消息是否已准备好从任何readfds读取？谢谢。
浏览 3提问于2014-10-02得票数 2
回答已采纳
我们有一个Lambda事件源，它轮询SQS中的消息并将它们传递给Lambda函数。
SQS有一个Visibility Timeout，它规定了消费者(lambda)在获得消息后多长时间内，如果没有成功完成，它将重新出现在队列中。
Lambda函数有没有办法在我们检测到错误时立即强制执行此操作？
例如，假设Lambda的超时时间为10分钟。SQS Visibility Timeout需要比这个更长。
但是，如果Lambda函数在早期检测到问题，并抛出一个错误--这将导致消息失败，但我们必须等待SQS Visibility Timeout，然后消息才能供其他使用者重试。
Lambda函数有没有办法
浏览 8提问于2021-10-12得票数 1
最近需要对SQS消息设置一些非常长的超时时间，并看到文档中的限制为12小时(43200)。因此，我尝试将超时设置为1下面，并得到了这个错误，这听起来很疯狂(因为在大多数数字系统中，43199实际上还不到43200 )。
SQSError: SQSError: 400 Bad Request SenderInvalidParameterValueValue 43199 for parameter VisibilityTimeout is invalid. Reason: Total VisibilityTimeout for the message is beyond the limit [43
浏览 6提问于2015-08-11得票数 8
回答已采纳
4回答
我在BizTalk中有一个业务流程，它是通过SAP服务收集数据的。
我的程序如下。
我们在接收端口上有一个SOAP服务，当我们收到来自SOAP的请求时，我们将其转换为SAP文件格式，并将其发送到SAP。当我们试图从SAP获得响应时，当响应数据很大时就会出现错误。如果响应消息大小如此之大，我们的服务将得到一个超时错误。否则，如果消息大小不是很大，就没有问题。
我试图在BizTalk管理控制台上延长超时时间，但仍然失败。不管我做了什么，超时时间总是在1分钟内。
在将下面的XML标记添加到machine.config文件后，我得到一个错误，如下图所示。
C:\Windows\Micros
浏览 5提问于2015-07-07得票数 4
回答已采纳
我想在订阅上设置拉请求的读取超时。现在，唯一的选项是设置returnImmediately=true或等待公共子返回，如果没有发布消息，这似乎是90秒。
我正在使用gcloud节点模块来调用pubsub。它使用遮罩下的模块进行gcloud调用。我更新了的本地副本，将请求超时设置为30秒
this.request({
method: 'POST',
uri: ':pull',
timeout: 30000,
json: {
returnImmediately: !!options.returnImmediately,
maxMess
浏览 2提问于2015-11-28得票数 5
我有一个WCF名称管道服务，用于在windows上通信两个进程。
我已经在我的机器上测试过它，它可以工作，我已经为它开发了一个安装程序，并且它对大多数用户都是有效的，但是一些用户正在获得一个带有以下消息的TimeoutException：
“发送到net.Pig://localhost/myService的请求操作没有在配置的超时(00:00:10)内收到答复。分配给此操作的时间可能是较长超时的一部分。这可能是因为服务仍在处理该操作，或者因为服务无法发送回复消息。请考虑增加操作超时(通过将通道/代理转换为IContextChannel并设置OperationTimeout属性)，并确保服务能够
浏览 2提问于2021-02-05得票数 0
我正在编写一个从服务器接收数据的Android应用程序。从理论上讲，不可能有互联网连接，所以我尝试通过捕获SocketTimeoutException来捕捉这种情况，以显示错误消息、重试屏幕或其他东西。不幸的是，这个异常不会被抛出。至少它没有跳到catch子句中。我做错了什么？
public class HttpConnector {
private String urlString;
private int connectionTimeout = 5000; //milliseconds
public HttpConnector(String urlString)
浏览 0提问于2012-02-04得票数 1
回答已采纳
问题的简短形式：如果处理消息的时间超过了给定的限制，我们希望抛出一个异常。
更长形式的问题：我们有几个以Windows的形式运行的内部应用程序，可以监听Azure服务总线订阅上的消息，以及写到Azure Blob存储的其他内容。
一般情况下，我们对服务总线或消息传递没有问题。服务总线SDK似乎工作得很好。
问题在于我们的应用程序逻辑，在收到消息之后，我们会对外部服务进行大量调用，比如SQL server。Oracle DB，blob存储，web API。我们发现对blob存储的调用突然开始挂起，即什么也没有发生，这在同一台机器上的几个应用程序中同时发生。其症状是消息未被处理。由于问题是由于某种
浏览 2提问于2020-09-23得票数 1
我正在实现一个简单的客户机/服务器读取器，我使用DataInputStream以字节的形式读取所有内容，然后处理解析工作。
这是我的阅读代码：
String line;
String requestString = "";
//client is a Socket that is initialized elsewhere
DataInputStream inputData = new DataInputStream(client.getInputStream());
byte [] messageByte = new byte[1024];
int counter = 0;
浏览 0提问于2018-09-14得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
