您现在的位置是：首页 > 其他

当前栏目

mq java_mq java client 方式和mq java binding方式的区别

服务器客户端连接

2023-03-02 10:28:30 时间

展开全部

MQ Java Binding方式使用JNI(Java Native Interface)类似于MQ 服务器应用程序。

MQSeries Java客户机服务器连接最快的方式是MQ Java Binding方式，这种方式要求MQ Java应用和e68a8462616964757a686964616f31333337376330MQ Server在同一台机器上。使用MQ Java Binding方式避免了建立网络连接的开销，因此，当连接对性能影响很大时，应当选用MQ Java Binding方式。

MQ Java Client方式通过Server端定义的服务器连接通道连接，服务器方需要启动侦听程序。MQ Java Client方式用于Java客户程序和服务器不在同一台机器时进行连接。

客户端连接，建立MQEnvironment类

MQEnvironment.hostname

以下是，客户端连接例子

// ===========================================================================

// Licensed Materials - Property of IBM

// 5639-C34

// (c) Copyright IBM Corp. 1995,1999

// ===========================================================================

// WebSphere MQ M'z Java f sample applet

// This sample runs as an applet using the appletviewer and HTML file,

// using the command :-

// appletviewer MQSample.html

// Output is to the command line, NOT the applet viewer window.

// Note. If you receive WebSphere MQ error 2 reason 2059 and you are sure your

// WebSphere MQ and TCP/IP setup is correct,

// you should click on the "Applet" selection in the Applet viewer window

// select properties, and change "Network access" to unrestricted.

import com.ibm.mq.\*; // Include the WebSphere MQ classes for Java package

public class MQSample extends java.applet.Applet

private String hostname = "your\_hostname"; // define the name of your

// host to connect to

private String channel = "server\_channel"; // define name of channel

// for client to use

// Note. assumes WebSphere MQ Server

// is listening on the default

// TCP/IP port of 1414

private String qManager = "your\_Q\_manager"; // define name of queue

// manager object to

// connect to.

private MQQueueManager qMgr; // define a queue manager object

// When the class is called, this initialization is done first.

public void init()

// Set up WebSphere MQ environment

MQEnvironment.hostname = hostname; // Could have put the

// hostname & channel

MQEnvironment.channel = channel; // string directly here!

MQEnvironment.properties.put(MQC.TRANSPORT\_PROPERTY,//Set TCP/IP or server

MQC.TRANSPORT\_MQSERIES);//Connection

\} // end of init

public void start()

try \{

// Create a connection to the queue manager

qMgr = new MQQueueManager(qManager);

// Set up the options on the queue we wish to open...

// Note. All WebSphere MQ Options are prefixed with MQC in Java.

int openOptions = MQC.MQOO\_INPUT\_AS\_Q\_DEF |

MQC.MQOO\_OUTPUT ;

// Now specify the queue that we wish to open, and the open options...

MQQueue system\_default\_local\_queue =

qMgr.accessQueue("SYSTEM.DEFAULT.LOCAL.QUEUE",

openOptions);

// Define a simple WebSphere MQ message, and write some text in UTF format..

MQMessage hello\_world = new MQMessage();

hello\_world.writeUTF("Hello World!");

// specify the message options...

MQPutMessageOptions pmo = new MQPutMessageOptions(); // accept the defaults,

// same as

// MQPMO\_DEFAULT

// constant

// put the message on the queue

system\_default\_local\_queue.put(hello\_world,pmo);

// get the message back again...

// First define WebSphere MQ message buffer to receive the message into..

MQMessage retrievedMessage = new MQMessage();

retrievedMessage.messageId = hello\_world.messageId;

// Set the get message options..

MQGetMessageOptions gmo = new MQGetMessageOptions(); // accept the defaults

// same as

// MQGMO\_DEFAULT

// get the message off the queue..

system\_default\_local\_queue.get(retrievedMessage, gmo);

// And prove we have the message by displaying the UTF message text

String msgText = retrievedMessage.readUTF();

System.out.println("The message is: " + msgText);

// Close the queue

system\_default\_local\_queue.close();

// Disconnect from the queue manager

qMgr.disconnect();

// If an error has occurred in the above, try to identify what went wrong.

// Was it WebSphere MQ error?

< 1. WebSphere MQ classes for Java >\} applet (2/3)

>\}zk

62 WebSphere MQ 9C Java

>\}&CLrzk

TBzkN\]>;vr%D&CLr,|9Cs(==:

1. ,S=SP\\mw

2. +\{"Ek SYSTEM.DEFAULT.LOCAL.QUEUE

3. YN!5XD\{"

catch (MQException ex)

System.out.println("WebSphere MQ error occurred : Completion code " +

ex.completionCode +

" Reason code " + ex.reasonCode);

// Was it a Java buffer space error?

catch (java.io.IOException ex)

System.out.println("An error occurred whilst writing to the

message buffer: " + ex);

\} // end of start

\} // end of sample

本回答由提问者推荐

![2Q==][2Q]

已赞过

已踩过<

你对这个回答的评价是？

收起

[2Q]:

猜你喜欢

pytest + yaml 框架 -10.生成 allure 报告
「  谈谈为什么使用typecho  」
「  简述网上常见的几种linux的网站管理面板  」
pytest + yaml 框架 -11.全局 base_url 配置
带你走进PHP session反序列化漏洞
「  [docker]遇到宝塔docker服务未启动的解决办法  」
Spring学习笔记 - IOC
pytest + yaml 框架 -12.支持执行sql 和断言sql
「  【QEMU】谈谈如何在linux系统上面搭建虚拟机  」
「  浅谈【SWAPIDC】想做一个IDC分销商吗  」
【Java 代码审计入门-03】XSS 漏洞原理与实际案例介绍
【Java 代码审计入门-01】审计前的准备
软件开发入门教程网 Search之MySQL 元数据
「  <TEST>【UNT401H】如何不刷固件安装第三方APP  」
pytest + yaml 框架 -13.多环境配置切换
挖洞神器之XRAY使用初体验
由定界符引发的一些安全问题
「  [青小益]谈谈建站十一天来的收录.....  」
PHPmyadmin SQL injection in Designer feature 研究（CVE-2019-18622）
「  [EtchDroid]如何用你的手机把U盘变成启动盘，用来重装系统  」

zl程序教程

当前栏目

mq java_mq java client 方式和mq java binding方式的区别

相关文章