实时搜索: mq怎么用

mq怎么用

637条评论 1070人喜欢 2636次阅读 398人点赞
MQA82CH/A iPhoneX 怎么用了联通卡 只有3G信号 没有4G信号 , 设备直接发送信息至服务器的61616端口(没有额什么的就直接发) 用MQ去监听 怎样接收的问题
真心不会 度娘也没有 求回答 , 我买了mq50电子管掉了,4个大管和4个小管现在不知道配什么管性价比高,还有4个小电子管网上看到是两个型号也不知道那个位插哪个型号,请知道的烧友指点,万分感谢!!! ...

如何使用 WebSphere MQ 的引用消息传输文件: 使用引用消息传送文件

以下操作均以admin用户为例:
1. 将admin用户加入administrator和mqm用户组,重新登录;
2. 修改MQ服务的登录用户为admin(如图一),然后重新启动MQSeries服务;

图一

3. 修改MQ DCOM组件的登录用户为“启动用户”,这样当以admin用户使用MQ资源管理器时,该DCOM组件将以admin用户的身份运行(如图二);关闭MQ资源管理器并重新打开,以使修改生效。

图二

图三
4. 启动Queue Manager,以QMA(发送文件,在MACHINE1服务器上)和QMB(接受文件,在MACHINE2服务器上)为例;
5. 创建MQ对象:

1)在QMA上:
define chl(chl1) chltype(sdr) trptype(tcp) conname('machine2') +
xmitq(xmitq) msgdata(FLATFILE) +
msgexit(' D:\IBM\WMQ\Tools\c\Samples\Bin\amqsxrm(MsgExit) ')

define ql(xmitq) usage(xmitq)

define chl(report) chltype(rcvr) trptype(tcp) replace

define qr(qr) rname(dq) rqmname(QMB) xmitq(xmitq) replace

2)在QMB上:
define chl(chl1) chltype(rcvr) trptype(tcp) +
msgexit(' D:\IBM\WMQ\Tools\c\Samples\Bin\amqsxrm(MsgExit) ') +
msgdata(FLATFILE)

define chl(report) chltype(sdr) trptype(tcp) conname('MACHINE1')
xmitq(QMA)

define ql(QMA) usage(xmitq)

注:如果使用MQ提供的接样例程序amqsgrm.exe接收文件,则作以下3)之后的设置,也可另写接受程序直接接收消息并获得已送达数据文件的名称。
3)在QMB上(可选):
define ql(initq)

define pro(proc) applicid('D:\IBM\WMQ\Tools\c\Samples\Bin\amqsgrm')

define ql(dq) initq(initq) process(proc) trigger trigtype(first)

在 MQ 服务中为 QMB 创建“触发器监控器”服务,设定监控队列为 INITQ ;并启动;

6. 在发送端启动发送通道chl1,在接收端启动发送通道report;

此时所有的配置已经完成,可以使用样例中的amqsprm.exe程序发送文件:
amqsprm -m QMA -i d:\tmp\src\srcfile.name -o d:\tmp\dest\destfile.name -q QR -t FLATFILE -w 10

7. 查验d:\tmp\dest\destfile.name文件已经产生。

MQA82CH/A iPhoneX 怎么用了联通卡 只有3G信号 没有4G信号: 建议核实当前使用的手机型号是否支持联通4G网络,4G网络制式为:TD-LTE和FDD-LTE。
使用联通4G网络还需要满足下列条件:
1、所在位置有联通3G或4G信号的覆盖;
2、手机卡已开通4G上网功能。
若均满足上述条件,仍无法使用联通4G网络,可联系客服咨询。

objective-c 怎么调用mq: /*
* 创建日期 2012-7-10
*
* TODO 要更改此生成的文件的模板,请转至
* 窗口 - 首选项 - Java - 代码样式 - 代码模板
*/
package yerasel;

/**
* @author Fenglb E-mail:56553655@163.com
* @version 创建时间:2009-4-30 下午04:13:38 类说明
*/

import java.io.IOException;
import com.ibm.mq.MQC;
import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;

interface SomeConstants {
String qManager = "XIR_QM_1502";//"XIR_QM"; //QueueManager name
String qName = "ESBREQ";// Queue Name
String strIP = "10.23.117.134";//"10.24.28.139";//"10.24.28.102";
int iPort = 1502;//1414;
String strChl = "SYSTEM.DEF.SVRCONN";// Server-Connection Channel
int iCCSID = 1208;
}

class Sender implements Runnable, SomeConstants {
public void run() {
sendMessage();
}

public void sendMessage() {

String name = Thread.currentThread().getName();
System.out.println("进入线程" + name);

MQQueueManager qMgr = null;
// configure connection parameters

MQEnvironment.hostname = strIP;
// Server name or IP
MQEnvironment.port = iPort;
MQEnvironment.channel = strChl;
MQEnvironment.CCSID = iCCSID;

// java程序连接mq的方式有两种,一是客户机方式,一是绑定方式,
// 默认是客户机方式,当mq部署在本地的时候,就需要用绑定方式
// 本机IP是10.24.28.139连接10.23.117.134的时候不需要下句
//MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,
//MQC.TRANSPORT_MQSERIES_BINDINGS);

// Create a connection to the QueueManager
System.out.println(name + " Connecting to queue manager: " + qManager);
try {
qMgr = new MQQueueManager(qManager);
// Set up the options on the queue we wish to open
int openOptions = MQC.MQMT_REQUEST | MQC.MQPMO_NEW_MSG_ID
| MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING
| MQC.MQOO_INPUT_AS_Q_DEF;
// Now specify the queue that we wish to open and the open options
System.out.println(name + " Accessing queue: " + qName);
MQQueue queue = qMgr.accessQueue(qName, openOptions);
// Define a simple WebSphere MQ Message ...

// Specify the default put message options
MQPutMessageOptions pmo = new MQPutMessageOptions();

// Put the message to the queue
System.out.println(name + " Sending a message...");

MQMessage msg = new MQMessage();
msg.messageId = "MSGID".getBytes();
msg.messageType = MQC.MQMT_REQUEST;
msg.replyToQueueName = "ESBREQ";

// 在此测试一下 mq 的传输次列
for (int j = 1; j < 5; j++) {
msg.messageSequenceNumber = j;
// write some text in UTF8 format
try {
String str = "Salemetsizbe Yerasel";
str = str + " " + j;
msg.writeUTF(str);
queue.put(msg, pmo);
msg.clearMessage();
System.out.println(name + " putting the message... " + j);
} catch (MQException mqe) {
mqe.printStackTrace();
break;
} catch (IOException e1) {
e1.printStackTrace();
}
}
qMgr.commit();
System.out.println(name + " Done!");
System.out.println("==========");
System.out.println("");
} catch (MQException e) {
e.printStackTrace();
}
}
}

class Receiver implements Runnable, SomeConstants {

public void run() {
recvMessage();
}

public void recvMessage() {

String name = Thread.currentThread().getName();

try {
Thread.sleep(1000);
MQQueueManager qMgr = null;

System.out.println("进入线程" + name);

System.out.println(name + " Connecting to queue manager: "
+ qManager);
qMgr = new MQQueueManager(qManager);
// 设置将要连接的队列属性
// Note. The MQC interface defines all the constants used by the
// WebSphere MQ Java programming interface
// (except for completion code constants and error code constants).
// MQOO_INPUT_AS_Q_DEF:Open the queue to get messages using the
// queue-defined default.
// MQOO_OUTPUT:Open the queue to put messages.
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT
| MQC.MQOO_INQUIRE;

// Now get the message back again. First define a WebSphere MQ
// message to receive the data
MQMessage rcvMessage = new MQMessage();

// Specify default get message options
MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.options = gmo.options + MQC.MQGMO_SYNCPOINT;// Get messages
// under sync point
// control(在同步点控制下获取消息)
gmo.options = gmo.options + MQC.MQGMO_WAIT; // Wait if no messages
// on the
// Queue(如果在队列上没有消息则等待)
gmo.options = gmo.options + MQC.MQGMO_FAIL_IF_QUIESCING;// Fail if
// Qeue
// Manager
// Quiescing(如果队列管理器停顿则失败)
gmo.waitInterval = 1000; // Sets the time limit for the
// wait.(设置等待的毫秒时间限制)

System.out.println(name + " Accessing queue: " + qName);
MQQueue queue = qMgr.accessQueue(qName, openOptions);
int depth = 0;

// Get the message off the queue.
System.out.println("... " + name + " getting the message back again");
for (;;) {
try {
queue.get(rcvMessage, gmo);
System.out.println(" ID: "
+ (new String(rcvMessage.messageId)).trim()
+ " Num: " + rcvMessage.messageSequenceNumber
+ " Type: " + rcvMessage.messageType + " Flag: "
+ rcvMessage.messageFlags);
// And display the message text...
String msgText = rcvMessage.readUTF();
System.out.println("The message is: " + msgText);
rcvMessage.clearMessage();

// Break if no MSG left in queue
depth = queue.getCurrentDepth();
if (depth == 0)
break;

} catch (MQException mqe) {
mqe.printStackTrace();
break;
// null;
} catch (IOException e) {
e.printStackTrace();
}
}
// Close the queue
System.out.println(name + " Closing the queue");
queue.close();
// Disconnect from the QueueManager
System.out.println(name + " Disconnecting from the Queue Manager");
qMgr.disconnect();
System.out.println(name + " Done!");
System.out.println("==========");
System.out.println("");
} catch (MQException ex) {
System.out
.println("A WebSphere MQ Error occured : Completion Code "
+ ex.completionCode + " Reason Code "
+ ex.reasonCode + ex.getMessage());
} catch (InterruptedException e1) {
e1.printStackTrace();
}
}
}

public class MQTest {

public static void main(String args[]) {

/*
* MQTest first = new MQTest(); first.sendMessage();
* first.recvMessage();
*/
Sender sender = new Sender();
Thread senderThread = new Thread(sender);
senderThread.start();
senderThread.setName("Sender");

Thread senderThread2 = new Thread(sender);
senderThread2.start();
senderThread2.setName("Sender2");

Receiver recv = new Receiver();
Thread recvThread = new Thread(recv);
recvThread.start();
recvThread.setName("Receiver");

// Receiver recv = new Receiver();
// new Thread(recv).start();

}

}

java ActiveMq与Tcp协议相关问题 ActiveMq怎样直接接收Socket的信息 socket没用队列什么的 Mq怎样接收: MQ 是应用层协议,TCP是网络层协议。他们不在一个层次。
MQ可以用TCP实现,也可以用UDP实现。

MQ的原理是基于消息的通信方式,Message Queue消息队列。
而消息队列一般都有API可以直接用,不用自己重新实现。

请问我在activeMQ里面放了很多队列。如何用java来遍历每个队列得到每个队列的状态和每个队列有多少跳记录: activemq 只能拿出来遍历,用监听触发局部变量,就可以知道有多少条信息,或者nowait方法 for循环遍历也可以;
你队列的状态指的是什么呢?

java 怎么样调用IBM MQ 或者通信问题:

websphere mq  : 用于传输信息 具有跨平台的功能。
1 安装websphere mq 并启动
2 websphere mq 建立 queue Manager (如:MQSI_SAMPLE_QM)
3 建立queue 类型选择 Local类型 的 (如lq  )
3 建立channels 类型选择Server Connection (如BridgeChannel)

java 代码如下:

package test.mq;
import com.ibm.mq.*;
/*
 * 成功的访问mq 的java 类
 */
public class FirstMqTest {
//    public static void main(String[] args[]){
//        FirstMqTest first = new FirstMqTest();
//        first.test();
//    }
    public static void main(String args[]){
        FirstMqTest first = new FirstMqTest();
        first.test();
        
    }
    public void test(){
        String qManager = "MQSI_SAMPLE_QM"; //QueueManager name
          String qName = "lq";//Queue Name
          try {
                    //configure connection parameters
                    MQEnvironment.hostname="172.16.17.123";//MQ Server name or IP
                    //MQEnvironment.port=1414;//listenr port
                    MQEnvironment.channel="BridgeChannel";//Server-Connection Channel
                    MQEnvironment.CCSID =1381;
                    // Create a connection to the QueueManager
                    System.out.println("Connecting to queue manager: "+qManager);
                    MQQueueManager qMgr = new MQQueueManager(qManager);
                    // Set up the options on the queue we wish to open 
                    int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;
                    // Now specify the queue that we wish to open and the open options
                    System.out.println("Accessing queue: "+qName);
                    MQQueue queue = qMgr.accessQueue(qName, openOptions);
                    // Define a simple WebSphere MQ Message ... 
                    MQMessage msg = new MQMessage();
                    // ... and write some text in UTF8 format
                    msg.writeUTF("Hello, World!");
                    // Specify the default put message options
                    MQPutMessageOptions pmo = new MQPutMessageOptions();
                    // Put the message to the queue
                    System.out.println("Sending a message...");
                    
                    /*
                     * 在此测试一下 mq 的传输次列
                     * 
                     */
                     for(int j=0;j< 5;j++){
                         String str ="test11111111111";
                         str = str+j;
                         msg.writeUTF(str);
                         queue.put(msg, pmo);
                     }
                    queue.put(msg, pmo);
                    // Now get the message back again. First define a WebSphere MQ message 
                    // to receive the data 
                    MQMessage rcvMessage = new MQMessage();
                    
                    // Specify default get message options 
                    MQGetMessageOptions gmo = new MQGetMessageOptions();
                    // Get the message off the queue.
                    System.out.println("...and getting the message back again");
                    queue.get(rcvMessage, gmo);
                    // And display the message text...
                    String msgText = rcvMessage.readUTF();
                    System.out.println("The message is: " + msgText);
                    // Close the queue
                    System.out.println("Closing the queue");
                    queue.close();
                    // Disconnect from the QueueManager
                    System.out.println("Disconnecting from the Queue Manager");
                    qMgr.disconnect();
                    System.out.println("Done!");
                }
                catch (MQException ex) {
                    System.out.println("A WebSphere MQ Error occured : Completion Code "
                            + ex.completionCode + " Reason Code " + ex.reasonCode);
                }
                catch (java.io.IOException ex) {
                    System.out.println("An IOException occured whilst writing to the message buffer: "
                            + ex);
                }
    }
}

各位热心网友你们好!请问力士MQ50后级功放用什么真空管好?其中4个小的安装顺序排列是怎样?感谢!: 50W纯甲类功放机的总体功率也就是额定不失真功率就是50W,但是他的实际耗电量要大得多,应该在300W以上。因为晶体管工作在纯甲类放大状态下它的线性最好、动态范围最大、不存在交越失真,比甲乙类推挽放大器的各项指标要高许多,所以倍受资深发烧友青睐,只是他的价格甚高!令人却步。
举个例子说吧:两只大功率晶体管组成的推挽甲乙类放大器能轻松的输出100W功率(指一个声道),那么相同型号的功率管工作在纯甲类状态下起码也得8只并联才能达到这个指标,而这8只晶体管要求性能参数完全相同,这需要在众多的晶体管中筛选,这也是纯甲类功放价格昂贵的最主要原因之一。
纯甲类功放机的功率管由于工作在甲类放大状态,他的静态电流很大,通常在3-5A左右,所以发热量巨大,耗电量也成倍增加。无论你开的音量大与小耗电量是不变的。

淘宝4700mq转针cpu怎么样 有用的吗:   理论上主要是阵脚数量一致接口也就是相同的,可以直接安插,但是也有特殊的,如三代和二代处理器在7系 6系主板上互插的时候可能会识别不了,此时就得更新BIOS解决
  英特尔最新推出了第六代酷睿产品,采用全新一代的架构,性能提示、功能降低、续航更加长久、无论办公学习、畅玩游戏或者观看超高清影音,均得心应手,您也可以试试。
  感谢您对英特尔产品的支持!

热门标签: mq怎么用 mq怎么用
  • pc如何双屏

    想知道:合肥市 从明珠广场到白龙出口(京台高速出口)怎么坐公交?: 从明珠广场先坐226到胜利广场站下车再做107到省第二人民医院下车再走到新蚌埠路上打出租车去,白龙在新蚌埠路的最北面,没有公交。 ...

    383条评论 4689人喜欢 4017次阅读 674人点赞
  • 10mg是多少克

    福建泉州和浙江嘉兴哪个地方离淮北近: 泉州离淮北约1316公里左右,嘉兴离淮北约599公里左右,嘉兴离淮北近。驾车路线:全程约1316.4公里起点:泉州市人民政府1.泉州市内驾车方案1) 从起点向东北方向出发,行驶180米,右转2) 行驶70米,左转进入...

    738条评论 3644人喜欢 5829次阅读 893人点赞
  • 五常稻花香谁研究的

    调和油炒菜为什么有辛辣味,: 正常来说油不会辣,是菜里面的辣味吧 ...

    847条评论 4743人喜欢 3943次阅读 567人点赞