注册 登录  
 加关注
   显示下一条  |  关闭
温馨提示!由于新浪微博认证机制调整,您的新浪微博帐号绑定已过期,请重新绑定!立即重新绑定新浪微博》  |  关闭

阿弥陀佛

街树飘影未见尘 潭月潜水了无声 般若观照心空静...

 
 
 

日志

 
 
关于我

一直从事气象预报、服务建模实践应用。 注重气象物理场、实况场、地理信息、本体知识库、分布式气象内容管理系统建立。 对Barnes客观分析, 小波,计算神经网络、信任传播、贝叶斯推理、专家系统、网络本体语言有一定体会。 一直使用Java、Delphi、Prolog、SQL编程。

网易考拉推荐

MQ客户端 Java  

2012-09-04 21:31:24|  分类: DOC |  标签: |举报 |字号 订阅

  下载LOFTER 我的照片书  |
2.5 JAVA接口使用说明及DEMO
说明:
客户端必须安装Websphere MQ 6.0 Client。
    接口文件为CdqxApi.jar。在JAVA工程中应包含此JAR文件。同时应包含MQ提供的com.ibm.mq.jar及connector.jar。

示例
package com.adv.client;

//import java.io.*;

public class RgribExample
{
    public static void main(String args[]) throws java.io.IOException
    {
        int i=0;
        //实例化接口
        ClientAPI capi = new ClientAPI("10.0.0.112");//IP地址为服务器IP
        //用于保存查询结果
        reqResult result;
        //保存消息ID
        byte msgId[]= new byte[48];
        //初始化API
        capi.initAPI();
        //设置元数据请求
        //请求结构化数据时此标志置0,请求读取BFILE时此标志置1
        int reqType=0;
        //模块号
        int reqParseLib=2;
        //读取元数据时此标志置1,读取数据时此标志置0
        int reqParseFunc=1;
        //请求元数据
        msgId=capi.applyReq(reqType,reqParseLib,reqParseFunc);
        //取回请求的元数据
        result=capi.getRusult(msgId);
        String[] metadata=result.rs.split("#");
        for(i=0;i<result.rsLines;i++)
        {
            System.out.println((i+1)+","+metadata[i]);
        }
        //设置数据请求
        reqParseFunc=0;
        int colNum=3; //请求数据列个数
        int conditionNum=1; //请求条件个数
        String colName[]=new String[500]; //以下为请求数据列中文名,来自于元数据
        colName[0]="入库时间";
        colName[1]="格点场文件名";
        colName[2]="文件长度";
        String conditionName[]=new String[500];//请求条件中文名,来自于元数据
        conditionName[0]="格点场文件名";
        int conditionOperator[]=new int[500];
        conditionOperator[0]=5;//请求条件操作符,5:“like”
        String conditionValue[]=new String[500];
        conditionValue[0]="spark"; //请求条件值
        int nextLinkCondition[]=new int[500];
        nextLinkCondition[0]=0; //与下一条件连接符,1:OR,0:AND
        int queryMonthCount=1; //请求月个数
        String queryMonthRange[]=new String[12];
        queryMonthRange[0]="02";  //请求月个数
        String tableName,fileName,fileLength;
        //发送请求
        msgId=capi.applyReq(
                reqType,
                reqParseLib,
                reqParseFunc,
                colNum,
                conditionNum,
                colName,
                conditionName,
                conditionOperator,
                conditionValue,
                nextLinkCondition,
                queryMonthCount,
                queryMonthRange
                );
        //第一次取回查询数据
        result=capi.getRusult(msgId);
        System.out.println(result.rs);
        //System.out.println(result.retCode);
        //System.out.println(result.totalLines);
        //取回剩余查询数据
        while(result.retCode==1)
        {
            result=capi.getRusult2(msgId);
            System.out.println(result.rs);
            //System.out.println(result.totalLines);
        }
        if(result.totalLines>5000)
            System.out.println("Warning:Data Line is Bigger Than 5000 Rows!");
        //取回非结构化数据
        reqType=1;
        result.retCode=1;
        tableName="RGRIB_IND_02"; //表名
        fileName="spark_2_5_8.exe"; //非结构化数据文件名
        fileLength="563200"; //非结构化数据文件长度
        int numOfFileBlock=1;
        msgId=capi.applyReq(tableName,fileName,fileLength);
        while(result.retCode==1)
        {
            result=capi.getResultNS(msgId);
            capi.writeBfile(result.nRs,numOfFileBlock);
            numOfFileBlock++;
        }
        //关闭API
        capi.closeAPI();
    }
}
  评论这张
 
阅读(882)| 评论(0)
推荐 转载

历史上的今天

在LOFTER的更多文章

评论

<#--最新日志,群博日志--> <#--推荐日志--> <#--引用记录--> <#--博主推荐--> <#--随机阅读--> <#--首页推荐--> <#--历史上的今天--> <#--被推荐日志--> <#--上一篇,下一篇--> <#-- 热度 --> <#-- 网易新闻广告 --> <#--右边模块结构--> <#--评论模块结构--> <#--引用模块结构--> <#--博主发起的投票-->
 
 
 
 
 
 
 
 
 
 
 
 
 
 

页脚

网易公司版权所有 ©1997-2017