import com.ibm.mq.*;
import lrapi.lr;public class Actions
{String PutQueueManagerName = "QMCPG1"; // 发送队列管理器String PutQueueName = "HVPSBANK"; // 发送队列名，相当于前置机的接收队列String QueueChannel = "xn_rcv"; // 通道名，要用服务器通道int PutPort = 1428; // 发送端口号，相当于前置机的接收端口int CCSID = 1381; // 客户端Unix用819，windows用1381int OpenOptions = MQC.MQOO_INPUT_AS_Q_DEF|MQC.MQOO_OUTPUT|MQC.MQOO_INQUIRE; // 连接参数int PutDepth = 0; // 发送队列深度String SndTime = ""; // 当前发送时间
MQQueueManager PutQueueManager = null; // 创建发送队列管理器对象MQQueue PutQueue = null; // 创建发送队列对象MQMessage PutMessage = new MQMessage(); // 创建发送消息对象MQPutMessageOptions PMO = new MQPutMessageOptions(); // 创建发送消息选项队列public int init() throws Throwable{// 发送队列的参数**********************************************MQEnvironment.hostname = lr.eval_string("<HostIP>"); // 设置环境参数MQEnvironment.port = PutPort;MQEnvironment.CCSID = CCSID; MQEnvironment.channel = QueueChannel;PutQueueManager = new MQQueueManager(PutQueueManagerName); // 连接发送队列管理器PutQueue = PutQueueManager.accessQueue(PutQueueName, OpenOptions, null, null, null); // 建立访问发送队列PutMessage.format = MQC.MQFMT_STRING; // 设置消息中应用数据的格式PutMessage.characterSet = 1381; // 设置字符集PutMessage.expiry = -1;    // 设置消息为不过期return 0;}//end of initpublic int action() throws Throwable{SndTime = String.valueOf(System.currentTimeMillis()); // 获取当前发送时间，13位lr.start_transaction("02_CP2I111_大额来帐_发送");PutQueueMessage("{H:" +"02" +"309391000011  " +"HVPS" +"306581000003  " +"HVPS" +"<Date>" + // 报文发起日期"<Time>" + // 报文发起时间"XML" +"hvps.111.001.01     " +SndTime + "<Num>" + // 通信级标识号，CNAPS2SIMU0000088212，20位，接收方根据OrigSender＋OrigSendDate＋MesgID唯一确定一个报文，该三项重复的报文作为通信级重复报文；SndTime + "<Num>" + // 通信级参考号，CNAPS2SIMU0000030415，20位，标识本报文的关联报文，由OrigSender设置，后续节点应保持该域不变，并在通信回应报文中带回该值，以便OrigSender匹配原报文；"3" +"D" +"         " +"}\r\n" +"{S:" + // 数字签名域起始标识"2016110700130322|2016-11-07T14:25:01|1|2016110700130322|A100|CNY10.05|NORM|309391000011|309391000011|306581000003|306588000016|321|123|309391000011|306588000016|xingneng|6214620421000208396|02102|" + // 数字签名内容"}\r\n" + // 数字签名域结束标识"<?xml version=\"1.0\" encoding=\"UTF-8\"?>" + "<Document xmlns=\"urn:iso:std:iso:20022:tech:xsd:pacs.008.001.02\">" + "<FIToFICstmrCdtTrf>" + "<GrpHdr>" + "<MsgId>" + "<Date>" + "<Time>" + "<MsgNum>" + "</MsgId>" + // 报文标识号，最大35位，最好是8位日期+8位流水，否则二代后台会处理异常，2016111015130018"<CreDtTm>2016-11-07T14:25:01</CreDtTm>" + "<NbOfTxs>1</NbOfTxs>" + "<SttlmInf>" + "<SttlmMtd>CLRG</SttlmMtd>" + "</SttlmInf>" + "</GrpHdr>" + "<CdtTrfTxInf>" + "<PmtId>" + "<EndToEndId>1</EndToEndId>" + "<TxId>" + SndTime + "<Num>" + "</TxId>" + // 交易标识号，最大35位，2016110700130322"</PmtId>" + "<PmtTpInf>" + "<CtgyPurp>" + "<Prtry>A100</Prtry>" + "</CtgyPurp>" +"</PmtTpInf>" +"<IntrBkSttlmAmt Ccy=\"CNY\">0.02</IntrBkSttlmAmt>" + // 金额"<SttlmPrty>NORM</SttlmPrty>" +"<ChrgBr>DEBT</ChrgBr>" +"<InstgAgt>" +"<FinInstnId>" +"<ClrSysMmbId>" +"<MmbId>309391000011</MmbId>" + // 付款清算行行号"</ClrSysMmbId>" +"</FinInstnId>" +"<BrnchId>" +"<Id>309391000011</Id>" + // 收款行行号"</BrnchId>" +"</InstgAgt>" +"<InstdAgt>" +"<FinInstnId>" +"<ClrSysMmbId>" +"<MmbId>306581000003</MmbId>" + // 收款清算行行号"</ClrSysMmbId>" +"</FinInstnId>" +"<BrnchId>" +"<Id>306588000016</Id>" + // 收款行行号"</BrnchId>" +"</InstdAgt>" +"<Dbtr>" +"<Nm>沈监</Nm>" + // 付款人名称"</Dbtr>" +"<DbtrAcct>" +"<Id>" +"<Othr>" +"<Id>6225684352000160189</Id>" + // 付款人账号"</Othr>" +"</Id>" +"</DbtrAcct>" +"<DbtrAgt>" +"<FinInstnId>" +"<ClrSysMmbId>" +"<MmbId>309391000011</MmbId>" + // 付款人开户行行号"</ClrSysMmbId>" +"</FinInstnId>" +"</DbtrAgt>" +"<CdtrAgt>" +"<FinInstnId>" +"<ClrSysMmbId>" +"<MmbId>306588000016</MmbId>" + // 收款人开户行行号"</ClrSysMmbId>" +"</FinInstnId>" +"</CdtrAgt>" +"<Cdtr>" +"<Nm>燕净</Nm>" + // 收款人名称"</Cdtr>" +"<CdtrAcct>" +"<Id>" +"<Othr>" +"<Id>6225684341000008415</Id>" + // 收款人账号"</Othr>" +"</Id>" +"</CdtrAcct>" +"<Purp>" +"<Prtry>02102</Prtry>" + // 业务种类编码"</Purp>" +"<RmtInf>" +"<Ustrd>/C00/2016-11-07</Ustrd>" + // 备注"</RmtInf>" +"</CdtTrfTxInf>" +"</FIToFICstmrCdtTrf>" +"</Document>");lr.end_transaction("02_CP2I111_大额来帐_发送",lr.PASS);return 0;}//end of actionpublic int end() throws Throwable{try{PutQueue.close();PutQueueManager.close();PutQueueManager.disconnect();}catch (MQException ex){lr.error_message("02_CP2I111_大额来帐_发送退出关闭队列时出现错误，完成代码为：" + ex.completionCode + "，原因为：" + ex.reasonCode);ex.printStackTrace();}catch(Exception e){e.printStackTrace();}return 0;}// end of end// 发送消息++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++public void PutQueueMessage(String MyStr){try{PutMessage = new MQMessage();PutMessage.write(MyStr.getBytes("UTF-8")); // 呵呵PutQueue.put(PutMessage, PMO);// 将消息放入队列PutQueueManager.commit(); // 提交事务处理//PutDepth = PutQueue.getCurrentDepth(); // 获取发送队列的深度//System.out.println("++++++发送队列当前深度为："+ PutDepth);//System.out.println("=======发送报文是：" + MyStr);
            PutMessage.clearMessage();PutMessage = null;}catch (MQException ex){lr.end_transaction("02_CP2I111_大额来帐_发送",lr.FAIL);lr.error_message("02_CP2I111_大额来帐_发送_发送消息时出错，完成代码为：" + ex.completionCode + "，原因为：" + ex.reasonCode + "流水号为：" + SndTime);lr.exit(lr.EXIT_ITERATION_AND_CONTINUE, lr.FAIL);//System.out.println("发送消息时出现错误，完成代码为：" + ex.completionCode + "，原因为：" + ex.reasonCode);//ex.printStackTrace();
        }catch(Exception e){e.printStackTrace();}    }
}

/** LoadRunner Java script. (Build: _build_number_)* * Script Description: *                     */
import java.util.Date;
import com.ibm.mq.*;
import lrapi.lr;public class Actions
{String GetQueueManagerName = "QMCPG1"; // 接收队列管理器String GetQueueName = "306581000003.MBFEA.PBCTOBANK";  // 接收队列名，相当于前置机的发送队列String QueueChannel = "xn_rsp"; // 通道名，要用服务器通道//String HostName = lr.eval_string("<HostIP>"); // ip 地址int GetPort = 1428; // 接收端口号，相当于前置机的发送端口int CCSID = 1381; // 客户端Unix用819，windows用1381int OpenOptions = MQC.MQOO_INPUT_AS_Q_DEF|MQC.MQOO_OUTPUT|MQC.MQOO_INQUIRE; // 连接参数int GetDepth = 0; // 接收队列深度
MQQueueManager GetQueueManager = null; // 创建接收队列管理器对象MQQueue GetQueue = null; // 创建接收队列对象MQMessage GetMessage = new MQMessage(); // 创建接收消息对象MQGetMessageOptions GMO = new MQGetMessageOptions(); // 创建接收消息选项对象public int init() throws Throwable{// 接收队列的参数***********************************************MQEnvironment.hostname = lr.eval_string("<HostIP>"); // 设置环境参数MQEnvironment.port = GetPort;MQEnvironment.CCSID = CCSID;MQEnvironment.channel = QueueChannel;GetQueueManager = new MQQueueManager(GetQueueManagerName); // 连接接收队列管理器GetQueue = GetQueueManager.accessQueue(GetQueueName, OpenOptions, null , null, null); // 建立访问接收队列GetMessage.format = MQC.MQFMT_STRING; // 设置消息体参数GetMessage.characterSet = 1381;GetMessage.expiry = -1;GMO.waitInterval = 20000; // 等待时间限制GMO.options = MQC.MQGMO_NO_WAIT; // 如果队列没有消息则立即返回return 0;}//end of initpublic int action() throws Throwable{String Msg = null;String NowTime = null;try{GetMessage = new MQMessage(); // 必须新建实例，否则无法多次迭代无法继续接收消息GetDepth = GetQueue.getCurrentDepth(); // 获取接收队列的深度 if(GetDepth > 0) //接收队列深度不为0则打印消息
            {GetQueue.get(GetMessage, GMO);GetQueueManager.commit();//System.out.println("======接收队列当前深度为："+ GetDepth);NowTime = String.valueOf(System.currentTimeMillis()); // 记录当前时间戳作为接收时间，13位Msg = GetMessage.readString(GetMessage.getMessageLength());CompResult(Msg,NowTime); // 记录接收时间、流水、交易码（所接收的交易返回信息不一定为当前程序发出的交易）//System.out.println("======接收消息的内容为：\n" + Msg);
                GetMessage.clearMessage();GetMessage = null;}else{System.out.println("++++++接收队列无消息++++++");}}catch(MQException ex){if(ex.reasonCode == 2033){// 2033是没有消息，不做处理
            }else{  lr.error_message("02_CP2I111_大额来帐_接收接收消息时出错，完成代码为：" + ex.completionCode + "，原因为：" + ex.reasonCode + "，流水号为：" + NowTime);ex.printStackTrace();}}catch(Exception e){e.printStackTrace();}return 0;}//end of actionpublic int end() throws Throwable{try{GetQueue.close(); // 关闭队列GetQueueManager.close(); // 关闭队列管理器GetQueueManager.disconnect(); // 断开连接
        }catch (MQException ex){lr.error_message("02_CP2I111_大额来帐_接收关闭队列时出现错误，完成代码为：" + ex.completionCode + "，原因为：" + ex.reasonCode);ex.printStackTrace();}return 0;}// end of end// 统计交易结果public void CompResult(String MSG, String RecTime){boolean Result = true; // 交易是否成功String StartTime = null;double DurTime = 0; // 交易处理时间int FlowIndex = -1; // 位置String FlowNo = null;int ErrIndex = -1; // 错误码位置String ErrCode = null;FlowIndex = MSG.indexOf("<MsgId>"); // 流水号的位置StartTime = MSG.substring(FlowIndex+7, FlowIndex+7+13); // 从流水号获取开始时间DurTime = (Double.parseDouble(RecTime) - Double.parseDouble(StartTime))/1000; // 单位秒//lr.error_message("======处理时间是：" + DurTime + "发送时间是：" + StartTime + "接收时间是：" + RecTime + "返回报文是：" + MSG);ErrIndex = MSG.indexOf("<MsgPrcCd>"); // 错误码的位置ErrCode = MSG.substring(ErrIndex+10, ErrIndex+10+8); // 错误码if(!ErrCode.equals("CU0I0000")) // 成功状态码是CU0I0000，交易失败则获取流水号
        {Result = false;FlowNo = MSG.substring(FlowIndex+7, FlowIndex+7+13); // 流水号lr.error_message("02_CP2I111_大额来帐_接收交易失败！出错流水号是：" + FlowNo + "，错误码是：" + ErrCode + "，完整出错信息是：" + MSG);}// 统计事务响应时间和成功率if(Result){lr.set_transaction("02_CP2I111_大额来帐_接收", DurTime, lr.PASS);//lr.error_message("======02_CP2I111_DELZ交易事务处理时间是：" + DurTime);
        }else{lr.set_transaction("02_CP2I111_大额来帐_接收", DurTime, lr.FAIL);}}
}// 正确返回报文：
//{H:02306581000003  HVPS309391000011  HVPS20161110164516XMLccms.990.001.02     20161110HVPS00062057012016111016501100013U         }
//<?xml version="1.0" encoding="UTF-8"?>
//<Document xmlns="urn:cnaps:std:ccms:2010:tech:xsd:ccms.990.001.02"><ComConf><ConfInf><OrigSndr>309391000011</OrigSndr><OrigSndDt>20161110</OrigSndDt><MT>hvps.111.001.01</MT><MsgId>01201611101650110001</MsgId><MsgRefId>01201611101650110001</MsgRefId><MsgPrcCd>CU0I0000</MsgPrcCd></ConfInf></ComConf></Document>