进程异常退出后 Go Channel中未消费的消息怎么办？
在Go语言中，当一个进程异常退出时，可能会导致Channel中的消息未被消费。为了解决这个问题，可以采用以下方法：
- 使用defer关键字：在发送和接收消息时，使用defer关键字来确保Channel中的消息被正确处理。
func main() {
ch := make(chan int)
go func() {
defer close(ch)
for i := 0; i < 10; i++ {
ch <- i
}
}()
for {
select {
case msg, ok := <-ch:
if !ok {
return
}
fmt.Println(msg)
}
}
}- 使用sync.WaitGroup：在程序中使用sync.WaitGroup来等待所有的goroutine完成，从而确保Channel中的消息被正确处理。
func main() {
ch := make(chan int)
var wg sync.WaitGroup
wg.Add(1)
go func() {
defer wg.Done()
for i := 0; i < 10; i++ {
ch <- i
}
}()
go func() {
wg.Wait()
close(ch)
}()
for msg := range ch {
fmt.Println(msg)
}
}- 使用context包：在程序中使用context包来管理goroutine的生命周期，从而确保Channel中的消息被正确处理。
func main() {
ctx, cancel := context.WithCancel(context.Background())
ch := make(chan int)
go func() {
defer close(ch)
for i := 0; i < 10; i++ {
select {
case ch <- i:
case <-ctx.Done():
return
}
}
}()
for {
select {
case msg, ok := <-ch:
if !ok {
return
}
fmt.Println(msg)
case <-ctx.Done():
return
}
}
cancel()
}通过以上方法，可以确保在进程异常退出时，Channel中的消息得到正确处理。
相关·内容
有很多例子说明如何使用WaitGroup来等待一组goroutines的全部完成，但是如果您想在不使用某个进程必须等待的信号量系统的情况下等待它们中的任何一个完成怎么办？在这种情况下：
我们不能仅仅使用标准的生产者/消费者信号量系统，因为生产:消费不是1:1，也是因为数据结构充当缓存，所以生产者可以“自由运行”，而不是阻止直到消费者“准备好”消费他们的</em
浏览 0提问于2018-02-02得票数 2
我实现了一个使用者，如果基础连接关闭，它将在一段时间后自动重新连接到代理。我的情况如下：
发布第三条信息，消费者成功地收到了。在这种情况下，在重新连接之前发布
浏览 2提问于2013-08-09得票数 4
回答已采纳
2回答
我的应用程序将消息发送到RabbitMQ exchange，然后exchange将消息重定向到绑定队列。我使用Springframework AMQP java插件和RabbitMQ。问题:消息进入队列，但它停留在“未确认”状态，它永远不会变成“就绪”。
可能的原因是什么？
浏览 0提问于2012-08-13得票数 24
回答已采纳
我有一个脚本，它应该要求一个密码，并告诉我是得到了正确的密码还是离开了，当我输入错误的密码时，我会收到这样的警告：“用户代码的异常”。#!\n";if ($password ne $guess) {}Uncaught exception from user code
Go</e
浏览 0提问于2015-11-09得票数 2
以下是我的路线定义 camelContext.addRoutes(new RouteBuilder() { public void configureatomicLong.decrementAndGet()); })
}
}); 当我将500条消息推送到此队列时，当停止和启动路由时，通道上的所有消息都将丢失，不知道它们要去哪里。如果我使用&autoA
浏览 63提问于2020-04-05得票数 0
回答已采纳
我已经使用了spring io文档中列出的示例配置，它工作得很好。<int-kafka:message-driven-channel-adapter listener-container="container1，我从kafka中消费并将其发布到下游。如果下游已关闭，则消息仍在使用中，不会重播。
或者假设从kafka主题消费后，如果
浏览 4提问于2017-08-07得票数 0
我使用手动kafka commit，将属性enable.auto.commit设置为false，同时初始化Kafka消费者，并在接收和处理消息后手动调用kafka commit。然而，因为在我的消费者中处理消息是很耗时的，所以我得到了Exception with message "error": "Broker: Group rebalance in progress"
原因是重新平衡超时后提交被拒绝现在，恢复操
浏览 15提问于2020-05-19得票数 0
我希望跨多个python进程共享BlockingChannel。以便从其他python进程发送basic_ack。我尝试过使用pickle转储，但它允许转储通道，并使用折叠代码提供错误can't pickle select.epoll objects
filepath= "temp/" + "merger_
浏览 0提问于2019-01-17得票数 2
回答已采纳
我正在尝试模拟这样一种场景:我连接到一个消息队列，然后在网络故障之后(在我的例子中是断开与VPN的连接)，我的进程尝试在无限的while循环中重新连接到一个消息队列。这是我的代码，看起来像是在做我想做的事情，但问题是，在断开VPN连接后，这个过程仍然保留在'my_queue‘上的消费者列表中，当重新连接到VPN时，一个新的</e
浏览 34提问于2019-06-06得票数 1
我正在运行一个测试，并试图让两个RabbitMQ使用者共享从队列中拉出的消息。但是，每次我运行它时，只有一个订阅者/消费者处理所有消息。为什么？ 我有一个单独的进程，它将10个样本消息放到队列中。Console.WriteLine("Press any key to close."); }
} 下面是每个线程使用的消费
浏览 67提问于2020-12-15得票数 0
回答已采纳
我需要一个设置，多个消费者应该连续地监听一个队列。我能够启动多个消费者和处理工作，如预期。但是过了一段时间之后，当没有消息要处理时，消费者就会被以下异常消息自动杀死。No handlers could be found for logger "pika.adapters.base_connection"
是否可以设置侦听队列的进程可以连续运行的设置？我在Python2.7中使用RabbitMQ 3
浏览 4提问于2014-04-24得票数 0
2回答
使用上面的代码，我能够使用由多个生产者发送到具有不同路由关键字的相同交换的多个消息，并且能够将每个消息插入到数据库。在BasicQos中将消息限制设置为10之后，我的期望是Console.WriteLine必须写入10条消息，但并不是预期的那样。我的期望是使用队列
浏览 8提问于2016-08-09得票数 9
回答已采纳
/isolated_platform_channel_middleware.dart:29:25:错误:未为类'BinaryMessenger‘定义方法'setMockMessageHandler’。，或定义名为“setMockMessageHandler”的方法。platformMessenger.setMockMessageHandler(channel，(消息){ ^^^^^^^^^^^^^^^^^^^^^
失败:生成失败，出现异常。进程</e
浏览 2提问于2021-06-17得票数 0
1回答
我从来没有发现这些信息中的任何一个是useful....Is，我没有机会解释这些信息到底出了什么问题？我到处寻找一张解释错误的表格，但什么也没有。我唯一能从上面的代码中破译的是退出代码52，但这是因为我看了源代码。它是说那是一个OOM。
我是否应该停止试图解释这些退出代码和退出状态？还是我错过了一些明显的方法，这些数字实际上意味着什么？即使有人能告诉我exit code、exit status和SIGNAL之间的区别
浏览 2提问于2017-08-01得票数 35
回答已采纳
我有没有办法做到这一点：
我希望能够以异步方式通知消费者。直到现在我都在传递信息。我想知道是否有即时消费者，但如果没有，消息应该仍然在队列上。它似乎不是“立
浏览 1提问于2013-01-18得票数 1
回答已采纳
我使用共享存储的实时/备份，并且使用非事务JMS会话。我总是发送一条消息，我总是收到一条消息，然后确认和接收第二条消息后，成功的第一次确认。在我的非事务会话中，我得到了这个异常：
我又读了一遍消息(这对我的任务
浏览 1提问于2020-07-15得票数 0
我有以下代码来声明一个队列：Channel channel = connection.createChannelkryo.readObject(input, getQueueClass());}
如果我在一个包含大量对象的队列中运行它，在大约270万个对象之后，我会得到一个内存不足的异常</
浏览 0提问于2012-10-02得票数 10
回答已采纳
2回答
因此，对于RabbitMQ来说，我是新手，我实现了一个简单的生产者--使用者，对于我的用例，如果队列是空的，我需要停止这个使用者，但是我找不到任何解决方案。发件人： pika.ConnectionParameters(host='localhost'))
channel.queue_declare(queue='h
浏览 13提问于2022-03-12得票数 1
我找不到任何与这个问题相关的文档，因此出现了这个问题。当ackMode设置为MANUAL_IMMEDIATE时，如果@KafkaListener方法根本不调用acknowledgement.acknowledge()，但成功退出该方法而没有任何异常，会发生什么情况我们在我们的一个消费者中遇到了这个问题，并丢失了消息(准确地说，偏移量已移动，因为我们从未调用过acknowledgement.acknowledge()，所以我们预计偏移量不会移动)，这是预期的</e
浏览 241提问于2020-11-04得票数 0
2回答
当我尝试调试VisualC++ 2010中的代码时，在“输出”框中有一些通知：
加载'C:\Users\sinta\Documents\Visual 2010\Projects\latihan\Debug程序'1008 latihan.exe:原生‘与代码0 (0x0)一起退出。
浏览 6提问于2012-05-10得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
