温馨提示:本文翻译自stackoverflow.com,查看原文请点击:.net - How do I prevent RabbitMQ from naming threads?
.net rabbitmq log4net

.net - 如何防止RabbitMQ命名线程?

发布于 2020-04-09 11:12:01

在项目升级的某个时刻,我们开始注意到名称已分配给RabbitMq客户端线程。这会在我们的日志文件中引起大量垃圾邮件。

例如,一个典型的日志消息从此

2019-10-22 10:56:17,981 [7] INFO - Publishing 440d9474-7c96-4226-8023-ca086dc0e143.product.001 to 127.0.0.1:5672. 

对此:

2019-10-22 10:56:17,981 [WorkPool-Session#1:Connection(a0437bf5-25c9-44f7-9a66-d3173e692fb2,amqp:/127.0.0.1:5672)] INFO - Publishing 440d9474-7c96-4226-8023-ca086dc0e143.product.001 to 127.0.0.1:5672. 

是什么原因造成的,是否有办法将这种行为还原为以前的行为?逻辑没有改变,但项目已升级到.NET 472,并且某些Nuget软件包也已升级。

我们对RabbitMq客户端的线程名称不感兴趣-我们只关心数字线程ID。

编辑:

这是一个演示问题的小程序。您需要RabbitMQ服务器来连接相关详细信息。当客户端从队列中读取消息时,将记录这些消息:

    public static void Main(string[] args)
    {
        var logRepo = LogManager.GetRepository(Assembly.GetEntryAssembly());
        XmlConfigurator.Configure(logRepo, new FileInfo("log4net.config"));
        var logger = LogManager.GetLogger(Assembly.GetEntryAssembly(), "Console");

        var fact = new ConnectionFactory {HostName = "127.0.0.1", UserName = "guest", Password = "guest", Port = 5672 };
        var conn = fact.CreateConnection();

        var channel = conn.CreateModel();
        channel.ExchangeDeclare("demo", "topic");
        var queue = channel.QueueDeclare();
        channel.QueueBind(queue.QueueName, "demo", "*");
        var consumer = new EventingBasicConsumer(channel);

        consumer.Received += (sender, message) =>
        {
           logger.Info("Message Received!");
        };

        logger.Info("About to receive messages...");
        channel.BasicConsume(queue.QueueName, true, consumer);

        Console.ReadLine();
    }

log4net.config:

<?xml version="1.0" encoding="utf-8" ?>
<log4net>
  <root>
    <level value="DEBUG" />
    <appender-ref ref="Console" />
  </root>
  <appender name="Console" type="log4net.Appender.ConsoleAppender" >
    <layout type="log4net.Layout.PatternLayout">
      <conversionPattern value="%date [%thread] %c %-5level - %message%newline" />
    </layout>
  </appender>
</log4net>

Nuget版本:

log4net 2.0.8

RabbitMQ.Client 5.1.2

日志输出:

2020-01-31 16:13:43,556 [1]控制台信息-即将接收消息...

2020-01-31 16:13:43,807 [WorkPool-Session#1:Connection(aa8913fd-aec2-4bd8-9cdc-2efc4f484363,amqp://127.0.0.1:5672)]控制台信息-收到消息!

2020-01-31 16:13:43,807 [WorkPool-Session#1:Connection(aa8913fd-aec2-4bd8-9cdc-2efc4f484363,amqp://127.0.0.1:5672)]控制台信息-收到消息!

请注意如何命名RabbitMq使用者的线程ID。如果可能的话,我想恢复到以前的行为(数字线程ID)。

查看更多

提问者
ilitirit
被浏览
92
ilitirit 2020-02-01 05:26

我找到了令人反感的代码。实际上,观察到的行为是由于将我们的RabbitMq Client版本升级到5.x引起的(此代码在master分支上有所不同)。

#if NETFX_CORE
            System.Threading.Tasks.Task.Factory.StartNew(Loop, System.Threading.Tasks.TaskCreationOptions.LongRunning);
#else
            var thread = new Thread(Loop)
            {
                Name = "WorkPool-" + name,
                IsBackground = true
            };
#endif

https://github.com/rabbitmq/rabbitmq-dotnet-client/blob/5.x/projects/client/RabbitMQ.Client/src/client/impl/ConsumerWorkService.cs

如果您指定在对的PatternLayout log4net的“线程ID”,你只会得到线程ID ,如果未指定线程名。要回答我自己的问题,似乎没有一种方法可以轻松更改此行为。