当前位置:软件学习 > 其它软件 >>

Websphere MQ能实现这样的功能吗?在线等

客户端向MQ服务器发消息,消息一到就马上读取,传到一个存储过程中计算。计算完后将结果发回客户端。
--------------------编程问答-------------------- 可以实现的,需要实现MQ消息的读取并传送到存储过程,然后写回处理结果到队列 --------------------编程问答-------------------- MQ支持trigger方式,你可以用这种方式来得到消息,进行处理。 --------------------编程问答-------------------- 我刚刚接触MQ不怎么懂。请问具体的我要怎么做呀? --------------------编程问答-------------------- http://www.webspherechina.net/club/viewthread.php?tid=4315&extra=page%3D1 --------------------编程问答-------------------- 刚刚学习MQ,请那个高人。告诉我详细的做法。包括怎么在MQ配置及要写的代码 --------------------编程问答-------------------- MDB --------------------编程问答-------------------- 大哥们,你们知道怎么向MQ远程队列发送消息吗?(楼主不要生气啊) --------------------编程问答--------------------
 只要您上传图片,就有机会拿到我图网送出的数码奖品。去看看奖品区吧。现在注册我图网的会员就有30多万位了,所以真是可靠。只要您上传达到兑换奖品的分数。我图网就送出奖品。
我图网www.ooopic.com 有丰富的图片资源,特别是我图网的艺术字http://yishuzi.ooopic.com/其独特的设计风格,代表着中国千百年
文化知识,具有很好的收藏价值。艺术字设计寻求广大的合作者。与“艺术字”友情链接。我们的精彩在于我们行动的风采,赶快行动吧。
有兴趣的朋友可以点击艺术字 http://yishuzi.ooopic.com/我图网欢迎您。 --------------------编程问答-------------------- 可以做到的。。自己写一个程序同步杜塞在那个本地队列上接受消息,一接收到消息就通过你的代码执行存储过程然后把结果发给另外一个远程队列返回给客户端
大概的代码这样的,一开始的MQManager连接和MQQUEUE的连接我就不贴了
            MQGetMessageOptions mqGetMsgOpts;
            // 同步等待属性
            mqGetMsgOpts.Options += MQC.MQGMO_WAIT;
            // 等待间隔
            mqGetMsgOpts.WaitInterval = WaitInterval;

            // MQMessage instance
            mqMsg = new MQMessage();
while (blnIsContinue)
            {
                try
                {
                    // Clear Messages
                    mqMsg.ClearMessage();
                    mqMsg.CorrelationId = MQC.MQCI_NONE;
                    mqMsg.MessageId = MQC.MQMI_NONE;

                    mMQQue.Get(mqMsg, mqGetMsgOpts);

                    try
                    {
                        // 解析消息体
                        MessageBody mb = (MessageBody)(mqMsg.ReadObject());
                    }
                    catch (MQException ex)
                    {
                        throw ex;
                    }
                }
                catch (MQException mqe)
                {
                    // 队列中没有消息
                    if (mqe.Reason == MQC.MQRC_NO_MSG_AVAILABLE)
                    {
                        mbReturn.ReturnException = new Exception("no correct message in queue." + mqe.Message + " Reason Code:" + mqe.ReasonCode.ToString(), mqe);
                        blnIsContinue = false;
                        break;
                    }
                    else
                    {
                        // 异常日志 抛出IBM MQ异常
                        Exception ex = new Exception(mqe.Message + " Reason Code:" + mqe.ReasonCode.ToString(), mqe);
                        mbReturn.ReturnException = ex;
                        Log.Error(ex, true, "");
                    }
                    // objReturnMsg = null;
                }
            }// While (blnIsContinue) --------------------编程问答-------------------- 我也觉得用 MDB 消息驱动 Bean 更合适,人家设计 MDB 就是为了解决类似这样的问题。如果用 Trigger 的话在访问量大了就有问题,因为那个 trigger 启动进程是件浪费时间的操作
补充:企业软件 ,  WebSphere
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,