在项目升级过程中的某个时候,我们开始注意到名称被分配给了我们的 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 [工作池会话#1:连接(aa8913fd-aec2-4bd8-9cdc-2efc4f484363,amqp://127.0.0.1:5672(] 控制台信息 - 消息已收到!
2020-01-31 16:13:43,807 [工作池会话#1:连接(aa8913fd-aec2-4bd8-9cdc-2efc4f484363,amqp://127.0.0.1:5672(] 控制台信息 - 消息已收到!
请注意来自 RabbitMq Consumer 的线程 ID 是如何命名的。 如果可能的话,我想恢复到以前的行为(数字线程 ID(。
我找到了有问题的代码。 事实上,观察到的行为是由将我们的 RabbitMq 客户端版本升级到 5.x 引起的(此代码在主分支上是不同的(。
#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
如果在 log4net 的 PatternLayout 中指定"threadid",则只有在未指定线程名称的情况下才会获得线程 ID。 为了回答我自己的问题,似乎没有办法轻易改变这种行为。