求助 :发送消息缓冲区时发生输入输出错误

问题描述

我只是个实习生;很多东西都不懂;请大家解释的详细点谢谢做MQ的压力测试的时候;写了一个读string数组写入MQ的方法;结果出现如下错误MQJE001:发生MQException:完成码2,原因2009MQJE003:发送消息缓冲区时发生输入输出错误MQJE001:完成码2,原因2009com.ibm.mq.MQException:MQJE001:完成码2,原因2009atcom.ibm.mq.MQQueue.put(MQQueue.java:1207)atcom.ibm.mq.MQQueue.put(MQQueue.java:1227)错误不是一开始就出的;当写入一定数量的MQ时(数量不定);会出现该错误出错时不会结束进程;会继续执行下去;不过这个string数组里只写到出错的那条;解决方法是什么请问问题出在什么地方代码如下publicvoidsend(StringsendStr[],StringqManager,StringqName){try{MQQueueManagerqMgr=newMQQueueManager(qManager);intopenOptions=MQC.MQOO_INPUT_AS_Q_DEF|MQC.MQOO_OUTPUT;MQQueuequeue=qMgr.accessQueue(qName,openOptions,null,null,null);MQMessagemsg=newMQMessage();msg.format=MQC.MQFMT_STRING;msg.characterSet=1208;for(inti=0;i<sendStr.length;i++)if(sendStr[i]!=null){msg.write(sendStr[i].getBytes("UTF-8"));queue.put(msg);//经测试是执行到这句时出错;System.out.println("read"+i);}queue.close();qMgr.disconnect();}catch(MQExceptionex){ex.printStackTrace();}catch(java.io.IOExceptionex){System.out.println("AnIOExceptionoccuredwhilstwritingtothemessagebuffer:"+ex);}}

解决方案

本帖最后由 hellkasim 于 2011-07-18 14:27:58 编辑
解决方案二:
问题解决了;把MQMessagemsg=newMQMessage();msg.format=MQC.MQFMT_STRING;msg.characterSet=1208;从循环外放入循环体就完成了
解决方案三:
该回复于2011-07-26 10:51:11被版主删除
解决方案四:
该回复于2011-08-18 11:58:48被版主删除
解决方案五:
问题解决了;把MQMessagemsg=newMQMessage();msg.format=MQC.MQFMT_STRING;msg.characterSet=1208;从循环外放入循环体就完成了

时间: 2024-08-07 03:36:01

求助 :发送消息缓冲区时发生输入输出错误的相关文章

c++-求助 error C1001: 编译器中发生内部错误

问题描述 求助 error C1001: 编译器中发生内部错误 1>------ 已启动生成: 项目: ConsoleApplication13, 配置: Debug Win32 ------ 1> ConsoleApplication13.cpp 1>d:documentvisual studio 2013projectsconsoleapplication13consoleapplication13consoleapplication13.cpp(48): fatal error C

vs2008-求助 VS2008打开文件时发生这个错误

问题描述 求助 VS2008打开文件时发生这个错误 文档时发生错误"> 解决方案 这个提示是错误的文件打开模式,我查了下资料说是野指针诱发的(参考http://blog.sina.com.cn/s/blog_50053ae001011413.html)你改下程序执行路径,变成英文试试吧. 解决方案二: 文件打开错误,检查路径.文件名(特别是后缀和路径分隔符).文件是否存在或者被锁定.权限. 参考:http://bbs.csdn.net/topics/60252766 解决方案三: 1. 程

加入多人聊天后不能发送消息,也不能接收消息(有一定几率)

问题描述 环境和基本流程:1.android+环信客户端2.2.22.关闭了自动登录3.app在启动的时候会执行一次logout,在用户加入聊天的时候在执行login,并在回调中执行joinChatRoom问题:1.加入群聊,调用EMChatManager.getInstance().joinChatRoom成功,回调EMValueCallBack的onSuccess后,发送消息失败,也不能接收到其他人得消息,此问题在app第一次启动时几率很高(90%),再次调用joinChatRoom后90%

c++-求助0xC0000005: 读取位置 0x00000004 时发生访问冲突错误

问题描述 求助0xC0000005: 读取位置 0x00000004 时发生访问冲突错误 void DInputClass::GetInput() { HRESULT hr = m_KeyboardDevice->GetDeviceState(sizeof(m_keyBuffer), (void**)&m_keyBuffer); //在这里提示错误了 //获取键盘输入消息 if(hr) { m_KeyboardDevice->Acquire(); m_KeyboardDevice-&g

(unix domain socket)使用udp发送&gt;=128K的消息会报ENOBUFS的错误

1.Unix domain socket简介 unix域协议并不是一个实际的协议族,而是在单个主机上执行客户/服务器通信的一种方法,所用API于在不同主机上执行客户/服务器通信所有的 API(套接字API,如AF_INET.AF_INET6等类型的API)相同.unix域协议可以视为是进程之间本地通信IPC的一种. unix域提供两类套接口:字节流套接口(类似TCP)和数据报套接口(类似UDP).使用Unix域套接口的理由有三: Unix域套接口往往比位于同一主机的TCP套接口快出一倍. Uni

.net 4.0 winfrom 上传文件到服务器,出现“基础链接已经关闭:发送时发生意外错误”

问题描述 一.要求:1.应以编程方式自动上传,不应该使用浏览器上传2.上传方法错误,应该使用HTTPPOST,不应该使用HTTPGET3.应先产生一个XML文本型文件,接着以"multipart/form-data"方式上传,不应以数据流(Stream)方式上传二.上传类采用梅里之巅的三.出现错误在using(StreamrequestStream=request.GetRequestStream()){requestStream.Write(formData,0,formData.L

安卓环信sdk,发送消息怎么发不出去?错误404

问题描述 解决方案 @Override    public void onClick(View v) {        // TODO Auto-generated method stub        switch (v.getId()) {        case R.id.fasong:            String xiaoxi = text.getText().toString();            if (xiaoxi.equals("")) {        

理解Storm的内部消息缓冲机制

这篇文章是Apache Kafka的作者之一Michael G. Noll写的,他的博客地址在[这里]. 优化Storm计算拓扑性能的过程有助于我们理解Storm内部消息队列的配置和使用,在这篇简短的文章中,我将向大家解释并说明Storm(0.8或0.9版本)的一个工作进程(worker process)和与其相关的多个执行器线程是如何完成内部通信的. Storm工作进程(Worker processes)的内部消息机制 在以下各章节中,我会交替地使用消息(message)和元组(tuple)两

关于socket通信,多线程发送消息

问题描述 关于socket通信,多线程发送消息 最近在多线程中使用socket通信遇到的问题,场景是有多个线程需要用到同一个socket连接进行消息的发送,因为没有订具体的协议,所以对于发送(文本)消息,每次发送端发送1K字节,接收端每次接收1K字节,无效数据用0填充,正常情况下来说都没什么问题,但当接收方接收不过来时,由于发送方设置了发送超时(30ms),send会发出EWOULDBLOCK,这下问题来了,推消息设计时设置超时就是希望对方不收就扔掉, 那么如果收到EWOULDBLOCK 就返回