我使用 WebSphere MQ v7 Server 和 WebSphere MQ Client v7.5 以及 amqmdnet.dll 7.5.0.0 作为 .NET 库通过 WebSphere MQ 进行通信。有时,当我尝试从队列中读取 MQMessage
时,我会收到 MQException
,原因是 MQRC_RFH_FORMAT_ERROR
。
var message = new MQMessage();
queue.Get(message);
此行为似乎取决于消息的发送者及其内容。它通常不适用于不同平台上发送具有 float 或 double 属性的消息的系统。
最佳答案
这是 IBM 的 amqmdnet.dll 中的全局化错误。在客户端上打开 MQ 跟踪 (strmqtrc.exe
) 后,我尝试再次接收消息,并在跟踪文件之一中发现了这一点:
00001F21 11:48:00.351013 7104.1 : Exception received
System.FormatException
Message: Input string was not in a correct format.
StackTrace:
at System.Number.ParseSingle(String value, NumberStyles options, NumberFormatInfo numfmt)
at System.Convert.ToSingle(String value)
at IBM.WMQ.MQMarshalMessageForGet.GetValueAsObject(String dt, String propValue)
at IBM.WMQ.MQMarshalMessageForGet.ProcessAllAvailableRFHs()
00001F22 11:48:00.351115 7104.1 : We are not sucessful in parsing one of theRFH2Header.Raise the RFH_FORMAT exception and breakfurther processing in loop
00001F23 11:48:00.351825 7104.1 : MQException CompCode: 2 Reason: 2421
使用.NET Reflector反编译MQMarshalMessageForGet
显示了这个:
private object GetValueAsObject(string dt, string propValue)
{
...
switch (dt)
{
...
case "r4":
return Convert.ToSingle(propValue);
case "r8":
return Convert.ToDouble(propValue);
...
}
...
}
消息是在当前系统的文化中读取的,而不是在传输预期的文化中(在所有平台上应该是相同的)!重现问题的简单测试:
[Test]
public void PutAndGetMessageWithFloatProperty() {
using (MQQueue queue = _queueManager.AccessQueue(TestQueue, MQC.MQOO_OUTPUT | MQC.MQOO_INPUT_AS_Q_DEF))
{
Thread.CurrentThread.CurrentCulture = new CultureInfo("en-US");
MQMessage message = new MQMessage();
message.SetFloatProperty("TEST_SINGLE", 14.879f);
message.WriteString("some string");
message.Format = MQC.MQFMT_STRING;
queue.Put(message); // Writes property value as 14.879
Thread.CurrentThread.CurrentCulture = new CultureInfo("cs-CZ");
MQMessage readMessage = new MQMessage();
queue.Get(readMessage); // Throws MQException because 14,879 is correct format
queue.Close();
}
}
解决方法
我正在使用这个简单的作用域类:
public class CultureForThreadScope : IDisposable {
private readonly CultureInfo oldCulture;
public CultureForThreadScope(CultureInfo culture) {
oldCulture = Thread.CurrentThread.CurrentCulture;
Thread.CurrentThread.CurrentCulture = culture;
}
public void Dispose() {
Thread.CurrentThread.CurrentCulture = oldCulture;
}
}
我正在包装对范围的每个 Get
调用。
using (new CultureForThreadScope(CultureInfo.InvariantCulture)) {
destination.Get(message, getOptions);
}
关于c# - 在 .NET WMQ API 中接收 WebSphere MQ 消息有时会抛出 MQRC_RFH_FORMAT_ERROR,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/11829264/