Эбберс М. Введение в современные мейнфреймы: основы z/OS
Подождите немного. Документ загружается.
572 ПриложениеЕ
return Reason;
}
else
{
printf( «MQDISC SUCCESSFUL\n» );
return rc;
}
return(rc);
} /*end main*/
/***************************************************************/
/* Functions to display error messages */
/***************************************************************/
void errorMessage( char* msgStr, MQLONG CC, MQLONG RC )
{
printf( «***********************************************\n» );
printf( «* %s\n», msgStr );
printf( «* COMPLETION CODE : %09ld\n», CC );
printf( «* REASON CODE : %09ld\n», RC );
printf( “**********************************************\n” );
}
JCL-код, выполняющий компиляцию:
Пример E.10. ZSCHOLAR.PROGRAM.CNTL(MQPUT)
//GMULLERT JOB 1,GEORG,MSGCLASS=H,MSGLEVEL=(1,1),NOTIFY=&SYSUID
//* COMPILE MQ PROGRAM
//STEP1 EXEC PROC=EDCCB,
// INFILE=’ZSCHOLAR.PROGRAM.SRC(MQPUT)’,
// OUTFILE=’ZSCHOLAR.PROGRAM.LOAD(MQPUT),DISP=SHR’
//SYSLIB DD DSN=MQ531.SCSQC370,DISP=SHR
//BIND.CSQBSTUB DD DSN=MQ531.SCSQLOAD(CSQBSTUB),DISP=SHR
//BIND.SYSIN DD *
INCLUDE CSQBSTUB
/*
MQGET
Исходный код.
Пример E.11. ZSCHOLAR.PROGRAM.SRC(MQGET)
#pragma csect(code,”CSQ4BCK1”)
/* */
/* Define static CSECT name */
/* */
Программадляпрактическойработы 573
#pragma csect(static,”BCK1WS”)
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <cmqc.h>
#define maxMessageLength 65536
/* */
/* Function prototypes */
/* */
void usageError( char* programName );
void errorMessage( char* msgStr, MQLONG CC, MQLONG RC );
int main( int argc, char** argv )
{
/* */
/* API variables */
/* */
MQHCONN HConn = MQHC_DEF_HCONN;
MQHOBJ HObj;
MQLONG OpenOptions;
MQMD MsgDesc = { MQMD_DEFAULT };
MQOD ObjDesc = { MQOD_DEFAULT };
MQGMO GetMsgOpts = { MQGMO_DEFAULT };
MQLONG CompCode;
MQLONG Reason;
/* */
/* Parameter variables */
/* */
MQCHAR48 qMgr;
MQCHAR48 qName;
char msgBuffer[maxMessageLength];
int msgLength = maxMessageLength;
char persistent = ‘N’;
long rc = 0;
long dataLength;
char browseGet = ‘D’; /* destructive get */
char syncpoint = ‘N’; /* no Syncpoint */
memset( msgBuffer, ‘\0’, msgLength );
strcpy( qMgr, “MQ8H\0” );
strcpy( qName, “GMULLER\0” );
/* */
/* Connect to Queue Manager (MQCONN) */
/* */
MQCONN( qMgr,
&HConn,
&CompCode,
&Reason );
/* */
/* If connect failed then display error message and exit */
/* */
if( MQCC_OK != CompCode ) {
errorMessage( “MQCONN”, CompCode, Reason );
return Reason;
}
printf( “MQCONN SUCCESSFUL\n” );
/* */
/* Open Queue for input shared and browse. Fail the call if the */
/* queue manager is quiescing. */
/* */
OpenOptions = MQOO_INPUT_SHARED +
MQOO_BROWSE +
MQOO_FAIL_IF_QUIESCING;
strncpy( ObjDesc.ObjectName, qName, MQ_Q_NAME_LENGTH );
MQOPEN( HConn,
&ObjDesc,
OpenOptions,
&HObj,
&CompCode,
&Reason );
/* */
/* If open failed then display error message, */
/* disconnect from the queue manager and exit */
/* */
if( MQCC_OK != CompCode ) {
errorMessage( “MQOPEN”, CompCode, Reason );
rc = Reason;
MQDISC( &HConn,
&CompCode,
&Reason );
return rc;
}
printf( “MQOPEN SUCCESSFUL\n” );
574 ПриложениеЕ
Программадляпрактическойработы 575
/* */
/* Set persistence depending on parameter passed */
/* */
if( ‘P’ == persistent )
MsgDesc.Persistence = MQPER_PERSISTENT;
else
MsgDesc.Persistence = MQPER_NOT_PERSISTENT;
/* */
/* Set GetMsgOpts .. don’t wait if there are no messages on the */
/* queue, truncate the message if it does not fit into our */
/* buffer, perform data conversion on the message if required */
/* and if possible, and fail the call if the queue manager is */
/* quiescing. */
/* */
GetMsgOpts.Options = MQGMO_NO_WAIT +
MQGMO_ACCEPT_TRUNCATED_MSG +
MQGMO_CONVERT +
MQGMO_FAIL_IF_QUIESCING;
strncpy( MsgDesc.MsgId, MQMI_NONE, MQ_MSG_ID_LENGTH );
strncpy( MsgDesc.CorrelId, MQCI_NONE, MQ_CORREL_ID_LENGTH );
/* */
/* Set additional GetMsgOpts depending on parameters passed */
/* into program. */
/* */
if( (‘S’ == syncpoint) && (‘B’ != browseGet) )
GetMsgOpts.Options += MQGMO_SYNCPOINT;
else
GetMsgOpts.Options += MQGMO_NO_SYNCPOINT;
if( (‘B’ == browseGet) )
GetMsgOpts.Options += MQGMO_BROWSE_FIRST;
MsgDesc.Encoding = MQENC_NATIVE;
MsgDesc.CodedCharSetId = MQCCSI_Q_MGR;
/* GET */
MQGET( HConn,
HObj,
&MsgDesc,
&GetMsgOpts,
msgLength,
msgBuffer,
&dataLength,
&CompCode,
&Reason );
if( (MQCC_FAILED == CompCode) ) {
errorMessage( “MQGET”, CompCode, Reason );
rc = Reason;
}
else {
/* */
/* Only character data messages are correctly displayed */
/* by this code */
/* */
if (MQRC_TRUNCATED_MSG_ACCEPTED == Reason) {
msgBuffer??( msgLength - 1 ??) = 0;
printf( “Message received (truncated):\n%s\n”,
msgBuffer );
}
else {
msgBuffer??( dataLength ??) = 0;
printf( “Message received:\n%s\n”,
msgBuffer );
}
}
free( msgBuffer );
/* */
/* Close the queue and then disconnect from the queue manager */
/* */
MQCLOSE( HConn,
&HObj,
MQCO_NONE,
&CompCode,
&Reason );
if( MQCC_OK != CompCode ) {
errorMessage( “MQCLOSE”, CompCode, Reason );
rc = Reason;
}
else printf( “MQCLOSE SUCCESSFUL\n” );
MQDISC( &HConn,
&CompCode,
&Reason );
if( MQCC_OK != CompCode ) {
errorMessage( “MQDISC”, CompCode, Reason );
576 ПриложениеE
Программадляпрактическойработы 577
return Reason;
}
else {
printf( “MQDISC SUCCESSFUL\n” );
return rc;
}
return(rc);
} /*end main*/
/***************************************************************/
/* Functions to display error messages */
/***************************************************************/
void errorMessage( char* msgStr, MQLONG CC, MQLONG RC )
{
printf( “**********************************************\n” );
printf( “* %s\n”, msgStr );
printf( “* COMPLETION CODE : %09ld\n”, CC );
printf( “* REASON CODE : %09ld\n”, RC );
printf( “**********************************************\n” );
}
JCL-код, выполняющий компиляцию:
Пример E.12. ZSCHOLAR.PROGRAM.CNTL(MQGET)
//GMULLERT JOB 1,GEORG,MSGCLASS=H,MSGLEVEL=(1,1),NOTIFY=&SYSUID
//* COMPILE MQ PROGRAM
//STEP1 EXEC PROC=EDCCB,
// INFILE=’ZSCHOLAR.PROGRAM.SRC(MQGET)’,
// OUTFILE=’ZSCHOLAR.PROGRAM.LOAD(MQGET),DISP=SHR’
//SYSLIB DD DSN=MQ531.SCSQC370,DISP=SHR
//BIND.CSQBSTUB DD DSN=MQ531.SCSQLOAD(CSQBSTUB),DISP=SHR
//BIND.SYSIN DD *
INCLUDE CSQBSTUB
/*
Программа доступа к MQ на языке Jaa
Java-программа получает сообщение из очереди. Класс MessageHandler также содер-
жит класс для отправки сообщений.
Необходимо добавить com.ibm.mq.jar и connector.jar в CLASSPATH.
Все файлы находятся в «program sample\mq».
Программа запускается командой java -jar mqconnect.jar.
578 ПриложениеЕ
Пример E.13. MQReceiver.java
import com.ibm.mq.MQException;
public class MQReceiver {
public static void main(String[] args) {
// Connection settings
String hostname = “wtsc04.itso.ibm.com”;
String queueName = “GMULLER”;
int port = 1598; // mq port
String channel = “GMULLER.SERV”;
MessageHandler handler = new MessageHandler(hostname, port,
queueName,
channel);
String message;
try {
System.out.println(“Sending message...”);
handler.sendMessage(“Hello”);
//System.out.println(“Receiving message...”);
//message = handler.receiveMessage();
//System.out.println(“Message: “ + message);
System.out.println(“Finished”);
} catch (MQException e) {
if (e.reasonCode == MQException.MQRC_NO_MSG_AVAILABLE)
System.out.println(“No message in queue”);
else {
System.out.println(“Error getting message”);
e.printStackTrace();
}
}
}
}
Пример E.14. MessageHandler.java
import java.io.IOException;
import com.ibm.mq.*;
public class MessageHandler {
private String hostname;
private String queueName;
public MessageHandler(String hostname, int port, String
queueName, String channel) {
MQEnvironment.hostname = hostname;
MQEnvironment.port = port;
Программадляпрактическойработы 579
MQEnvironment.channel = channel;
this.queueName = queueName;
}
public String receiveMessage() throws MQException {
try {
MQQueueManager mqm = new MQQueueManager(hostname);
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF
+ MQC.MQOO_OUTPUT;
MQQueue queue = mqm.accessQueue(queueName, openOptions);
// create new Message for receiving
MQMessage message = new MQMessage();
// get message from queue
queue.get(message);
// get the whole message string
String messageString =
message.readString(message.getMessageLength());
// close queue;
queue.close();
// disconnect from queue manager
mqm.disconnect();
return messageString;
} catch (IOException e) {
e.printStackTrace();
return null;
}
}
public void sendMessage(String messageString) throws MQException {
try {
MQQueueManager mqm = new MQQueueManager(hostname);
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF +
MQC.MQOO_OUTPUT;
MQQueue queue = mqm.accessQueue(queueName, openOptions);
// create new Message for receiving
MQMessage message = new MQMessage();
// write message
message.writeString(messageString);
message.encoding = MQC.MQENC_NATIVE;
message.characterSet = MQC.MQCCSI_INHERIT;
// put message onto the queue
queue.put(message);
// close queue;
queue.close();
// disconnect from queue manager
mqm.disconnect();
} catch (IOException e) {
e.printStackTrace();
}
}
}
580 ПриложениеЕ
Справочныесведения 581
F
Справочные сведения
Это приложение содержит следующие сведения:
• Рекомендуемая литература.
• Глоссарий.