如何知道mq队列里面有多少数据
⑴ MQGET从MQ队列中是不是一次取一条数据
MQGET是逐条从队列中将消息取出，相应的队列中的消息递减，楼主可以通过观察队列的队列深度变化。
使用runmqsc 【队列管理器】，这里以本地队列为例dis ql(qname)，可以看CURDEAPTH属性
⑵ 如何获取当前连接到消息队列的连接数以及消息队列的queue数
第一个参数是消息队列对象的标识符。 第二个参数是消息队列的控制方式： IPC_STAT 取出系统保存的消息队列的msqid_ds数据，并将其存入参数buf指向的msqid_ds结构中。
⑶ 如何查看rabbitmq 队列内容
由于种种原因，RabbitMQ到目前为止，官方还没有实现优先级队列，只实现了Consumer的优先级处理。 但是，迫于种种原因，应用层面上又需要优先级队列，因此需求来了：如何为RabbitMQ加入优先级队列特性。
⑷ mq 可以查看发送队列深度么深度么
可以查看发送队列深度。解决方法如下：
1、首先上传ms03_unix.tar.Z到AIX服务器，并执行解压。# uncompress -c ms03_unix.tar.Z | tar xvf -。
⑸ 如何察看mq中queue的消息内容
工作中的一些体会：如何查看queue里的messages的content.
说实在的，MQ的东西很烦琐，虽然很强大。可是中文的资料太少（当然中文版的MQ会带些帮助文档，不过都是垃圾）；英文的太拗口（虽然我整天看英文的文档，还是看不太懂；要不就是MQ太庞大了？）
反正我只是在工作中学了那么一点点可怜的东西，就赶快写出来了。
据我所知，是有两种的方式来查看queue的content.
Prepare:
假设queue的名字叫做local.queue, queue manager的名字叫做 test.queue.manager，mq安装在/opt/mqm下.
1.先确定queue的长度不是0.
$runmqsc test.queue.manager
dis ql('local.queue') curdepth
2 : dis ql('local.queue') curdepth
AMQ8409: Display Queue details.
QUEUE(local.queue) CURDEPTH(1)
如上所示，queue里面是有一个message的，因为curdepth的长度为1.
2.查看queue的message的内容
第一种方式：使用/opt/mqm/samp/bin/amqsget
第二种方式：使用/opt/mqm/samp/bin/amqsbcg
共同点:
都是在命令后面先跟queue的名字，然后再跟queue manager的名字,如下
/opt/mqm/samp/bin/amqsget local.queue test.queue.manager
区别是：
前者只能查看短长度的message，并且会把message取出（还不是太确定后者）；遇到长度稍微长一点的就会发出2080的error code.
$/opt/mqm/samp/bin/amqsget local.queue test.queue.manager
Sample AMQSGET0 start
MQGET ended with reason code 2080
Sample AMQSGET0 end
而后者则没有这个限制；但是amqsbcg显示的message很奇特，连二进制的都同时显示
⑹ rocketmq mq 怎么查看队列中的数据
innodb_data_home_dir = /longxibendi/mysql/mysql/var/
#innodb_data_file_path = ibdata1:1G:autoextend
innodb_data_file_path = ibdata1:500M;ibdata2:2210M:autoextend #表空间
innodb_file_io_threads = 4 #io线程数
⑺ 请问用java连接MQ时,如何获得某一个队列管理器下所有队列名称。
引起这个问题一个很有可能的原因是队列管理器在不正常停止后，虽然ps -ef | grep mq看不到此队列管理器的进程，但此MQ队列管理器的进程占用的信号灯和共享内存却没有被释放掉。解决办法如下：
1. 先查看是否有此队列管理器残留的 信号灯和共享内存。命令如下：
ipcs -a | grep mq
2. 如果有，使用ipcrm命令清除 残留的信号灯和共享内存，命令如下：
ipcrm -s <semphore id>
ipcrm -m <shared memory id >
3. 再次启动MQ队列管理器
⑻ mq如何查队列管理器有什么队列
可以简单的把队列看作一个容器，用来存放消息。队列按其定义来分，可以分成本地队列、远程队列、别名队列和模型队列。其中本地队列是真正意义上的队列实体，可以用来存放消息。而远程队列和别名队列只是一种队列的定义，指向另一个队列实体。其中远程队列指向的是其他队列管理器中的队列，而别名队列指向的是本地队列管理器中的队列。模型队列有一点特殊，它虽然本身只是一个队列的定义，描述了模型的属性，但是当打开模型队列的时候，队列管理其就会以这个定义为模型，创建一个本地队列，被成为动态队列。
一个队列管理器可以管辖多个队列。但对于一个队列只能隶属于其中的一个队列管理器。所以队列在其所隶属于的队列管理器只能有唯一的名字，不能于同一个管理器中的其他的队列重名。当消息添加到队列中是，其缺省被添加到最后。删除消息时从头开始。
⑼ 请问我在activeMQ里面放了很多队列。如何用java来遍历每个队列得到每个队列的状态和每个队列有多少跳记录
activemq 只能拿出来遍历,用监听触发局部变量,就可以知道有多少条信息,或者nowait方法 for循环遍历也可以;
你队列的状态指的是什么呢?
⑽ java如何获取rabbitmq队列中消息数量
下面是RabbitMQ的消息确认机制：“为了确保消息不会丢失，RabbitMQ支持消息确认机制。客户端在接受到消息并处理完后，可以发送一个ack消息给RabbitMQ，告诉它该消息可以安全的删除了。假如客户端在发送ack之前意外死掉了，那么RabbitMQ会将消息投递到下一个consumer客户端。如果有多个consumer客户端，RabbitMQ在投递消息时是轮询的。RabbitMQ如何判断客户端死掉了？唯一根据是客户端连接是否断开。这里没有超时机制，也就是说客户端可以处理一个消息很长时间，只要没断开连接，RabbitMQ就一直等待ack消息。”我现在遇到的问题是这样的：我这边有几条线程去消息队列里取数据，但是会有异常数据导致线程挂掉，就是上边的“客户端在发送ack之前意外死掉了”，RabbitMQ会将消息投递到下一个consumer客户端，这样一条异常数据会把我的所有线程挂掉，我现在想实现这样的功能：如果有异常数据导致进程挂掉，那么我不让RabbitMQ将这条消息投递到下一个consumer客户端，而是放到另一个地方或者另外处理，请问该如何实现呢？