使用JAVA代码发送MQ消息

这一节介绍使用JAVA发送文本内容至MQ中 首先新建一个项目，导入必要的包，我记得，必要的包有6个，后来用了maven，我就把本地的删了，测试的时候，可以把jar全部丢进去，在MQ安装目录有个JAVA——lib文件夹，里面就是用到的架包了。 新建类RemoteTest 其他都我就不写了，稍后在文尾给个下载地址供大家参考。

这里的配置文件，大家可以手动改以下，由于我这里是将配置文件写在了properties文件里，大家根据自己喜好选择。 我的配置文件是：

队列管理器名称
Q_MANAGER = Test
主机
HOST_NAME = 10.10.10.223
端口
PORT = 1414
队列
MQ_NAME = QUEUE
通道
CHANNEL = CHANNEL
CCSID = 1383

发送的代码为：

/**
	 * 发送消息
	 */
	public static void sendMsg(String msgStr)
	{
		try
		{
			init();
			MQMessage qMsg = new MQMessage();
			qMsg.encoding = CCSID;
			qMsg.characterSet = CCSID;
			qMsg.writeString(msgStr);
			MQPutMessageOptions pmo = new MQPutMessageOptions();
			qQueue.put(qMsg, pmo);
			System.out.println("发送成功");
		} catch (MQException e)
		{
			System.out.println("发生了一起异常，异常原因：" + e.reasonCode);
		} catch (IOException e)
		{
			System.out.println("发生了一起IO异常：" + e.getMessage());
		} finally
		{
			finalizer();
		}
	}

/**
	 * 手动释放
	 */
	private static void finalizer()
	{
		try
		{
			qQueue.close();
			qMgr.disconnect();
		} catch (MQException e)
		{
			System.out.println("发生了一起异常，错误代码：" + e.reasonCode);
			e.printStackTrace();
		}
	}

接受的代码为：

/**
	 * 接收消息
	 * 
	 * @return
	 */
	public static String getMsg()
	{
		final MQMessage revMessage = new MQMessage();
		try
		{
			init();
			MQGetMessageOptions gmo = new MQGetMessageOptions();
			revMessage.characterSet = CCSID;
			revMessage.encoding = CCSID;
			gmo.options += MQC.MQPMO_SYNCPOINT;
			if (qQueue.getCurrentDepth() <= 0)
			{
				System.out.println("当前队列深度为0，队列中没有消息。");
				return null;
			}
			qQueue.get(revMessage, gmo);
			String revString = revMessage.readStringOfByteLength(revMessage.getMessageLength());
			return revString;
		} catch (MQException e)
		{
			if (e.reasonCode == 2033) // 没有消息
			{
				System.out.println("没收到消息！");
			}
		} catch (IOException e)
		{
			e.printStackTrace();
		} finally
		{
			finalizer();
		}
		return null;
	}

自此，就可以通过MQ队列接受和发送消息了。

下载地址： MQ錯誤代碼合集http://download..net/detail/u012552275/9781699

MQ的安裝及配置http://download..net/detail/u012552275/9781644

IBMMQ安裝教程http://download..net/detail/u012552275/9781643

java的配置文件http://download..net/detail/u012552275/9815568

MQ工具类http://download..net/detail/u012552275/9815577

远程测试http://download..net/detail/u012552275/9815574

其他博客： WebSphere MQ使用：http://blog..net/u012552275/article/details/70194285

使用JAVA代码发送MQ消息：http://blog..net/u012552275/article/details/70194644

JAVA发送接收MQ代码示例：http://blog..net/u012552275/article/details/70194969