0

我正在使用 IBM websphere XMS API 连接大型机并向其发送消息。但是，发送的每条消息都是通过一个新的本地端口发送的。有没有办法将其设置为固定端口？

命中以下行时，会在本地创建一个新端口：

var connContext = new XMSConnectionContext(connFactory.CreateConnection(), sendQ, replyQ, mqProfile, DateTime.Now.AddSeconds(qm.MqConfiguration.ConnectionPoolExpiryTime));

我正在使用的代码是

    public IMQMessage Message { get; set; }

    public void Initialise(IMQMessage message, QueueSet queueSet, QueueManager queueManager)
    {
        Message = message;
        if (_connContext.ContainsKey(message.MessageId)) return;
        _connContext.TryAdd(message.MessageId, ConnectQueueSet(queueSet, queueManager));
        _connContext[message.MessageId].Connection.Start();
    }

    private XMSConnectionContext ConnectQueueSet(MQQueueSet queueSet, QueueManager qm)
    {
        var mqProfile = GetProfile(queueSet);

        var xmsFactory = XMSFactoryFactory.GetInstance(XMSC.CT_WMQ);
        var connFactory = xmsFactory.CreateConnectionFactory();

        connFactory.SetStringProperty(XMSC.WMQ_HOST_NAME, mqProfile.ServerName);
        connFactory.SetIntProperty(XMSC.WMQ_PORT, mqProfile.Port);
        connFactory.SetStringProperty(XMSC.WMQ_CHANNEL, mqProfile.ChannelName);
        connFactory.SetStringProperty(XMSC.WMQ_QUEUE_MANAGER, mqProfile.QueueManagerName);
        connFactory.SetIntProperty(XMSC.WMQ_FAIL_IF_QUIESCE, 1);
        connFactory.SetIntProperty(XMSC.WMQ_SHARE_CONV_ALLOWED, XMSC.WMQ_SHARE_CONV_ALLOWED_YES);
        connFactory.SetIntProperty(XMSC.WMQ_CONNECTION_MODE, XMSC.WMQ_CM_CLIENT);

我们试过了

        connFactory.SetStringProperty(XMSC.XMSC_WMQ_LOCAL_ADDRESS,"(45000,45010)");

我们也试过

        connFactory.SetStringProperty(XMSC.XMSC_WMQ_LOCAL_ADDRESS,"localhost(45000,45010)");

我们也试过

        connFactory.SetStringProperty(XMSC.XMSC_WMQ_LOCAL_ADDRESS,"192.168.12.156(45000,45010)");

测试结束，下面的其余部分保持原样。

        IDestination sendQ = xmsFactory.CreateQueue(string.Format("queue://{0}/{1}?targetClient=1", mqProfile.QueueManagerName, mqProfile.RequestQueue));
        IDestination replyQ = xmsFactory.CreateQueue(string.Format("queue://{0}/{1}?targetClient=1", mqProfile.QueueManagerName, mqProfile.ReplyQueue));

        var connContext = new XMSConnectionContext(connFactory.CreateConnection(), sendQ, replyQ, mqProfile, DateTime.Now.AddSeconds(qm.MqConfiguration.ConnectionPoolExpiryTime));

        QueueManager.Log.DebugFormat("XMSConnectionContext-Instantiated: ProfileName={0} SendQ={1}, ReplyQ={2}, ConnectionMetaData={3}", connContext.ProfileName, connContext.SendQ, connContext.ReplyQ, connContext.Connection);

        return connContext;
    }

    public void Close()
    {
        if (_connContext != null)
        {
            _connContext[Message.MessageId].Connection.Stop();
        }

    }

任何帮助，将不胜感激。谢谢。

4

1 回答 1

0

XMS .NET 有一个连接工厂属性 XMSC_WMQ_LOCAL_ADDRESS，它允许您在连接到队列管理器时指定要使用的本地端口。更多细节在这里

于 2016-05-01T09:06:10.930 回答