用线程创建了3个customer,程序开启一段时间后，就不消费了 about newlife.rocketmq HOT 10 CLOSED

consumer孤零零的，过一会gc就该来收割它啦。
可以搞一个数组，把这些消费者对象管理起来

from newlife.rocketmq.

创建消费者的时候，没有必要异步，直接for循环好了，因为Start只是启动内部线程，并不阻塞

from newlife.rocketmq.

consumer孤零零的，过一会gc就该来收割它啦。 可以搞一个数组，把这些消费者对象管理起来

怎么管理呢？定时判断消费者是否存在吗？不存在了就重新创建一个新的？

from newlife.rocketmq.

弄一个全局变量，或者静态变量都行，只要有引用，GC就不会销毁它

from newlife.rocketmq.

弄一个全局变量，或者静态变量都行，只要有引用，GC就不会销毁它

好的，谢谢，另外一个问题，请有可以获取topic下queueid的方法吗？尝试用Queues，好像不行

from newlife.rocketmq.

弄一个全局变量，或者静态变量都行，只要有引用，GC就不会销毁它

public static List listConsumer = new List();
public void Start()
{
for (int i = 0; i < 3; i++)
{
var consumer = new Consumer
{
Topic = "bb",
NameServerAddress = "xx",
BatchSize = 3,
Group = "bbgroup"
};
consumer.OnConsume = (q, ms) =>
{
string mInfo = $"datetime={DateTime.Now},BrokerName={q.BrokerName},QueueId={q.QueueId},Length={ms.Length}";
Console.WriteLine(mInfo);
foreach (var item in ms.ToList())
{
string msg = $"消息：msgId={item.MsgId},key={item.Keys}，产生时间【{item.BornTimestamp.ToDateTime()}】，内容>{item.BodyString}";
LogHelper.Information("RocketMQConsumer", msg);
}
// return false;//通知消息队：不消费消息
return true; //通知消息队：消费了消息
};
consumer.Start();
listConsumer.Add(consumer);
}
}
这样用listConsumer来管理，还是只会执行一次，麻烦帮看下，谢谢

from newlife.rocketmq.

嗯，是这样，代码没有错。
可以看看日志。

from newlife.rocketmq.

感谢团队大佬贡献

from newlife.rocketmq.

问题解决了吗？

from newlife.rocketmq.

问题解决了吗？

解决了自动回收的问题，但是现在吃内存和CPU很历害，跑一会儿就占内存几G了。

from newlife.rocketmq.