1.blockedqueueԴ?源码?
2.怎样分析linux的性能指标
3.如何获取queueviewmbean对象
4.Python多进程系列之Queue类

blockedqueueԴ??

       please input task ID that was blocked by message queue,or 0 for all queue，

       è¯·è¾“入由消息队列阻塞的任务ID，或输入所有队列的0，

       please请; 讨好; 使高兴; 使满意; 讨人喜欢

       input输入，投入; 输入电路; <电>输入端; 输入的数据; 把…输入电脑; 输入; 输入，给料

       task作业; 工作，任务; 苦差事; 交给某人; 使过于劳累

       blocked封锁的，闭塞的，联锁的; 堵塞( block的过去式和过去分词 ); 阻碍; 设计; 阻挡

       message queue信息排队

       for all尽管， 虽然

       queue行列，长队; 辫子; 排队等候; 排队，列队等待

怎样分析linux的性能指标

       LR

       监控

       UNIX/Linux

       系统方法

       一、准备工作：

       1.

       可以通过两种方法验证服务器上是源码否配置

       rstatd

       守护程序：

       ①使用

       rup

       命令，它用于报告计算机的源码各种统计信息，其中就包括

       rstatd

       的源码mud架设源码配置信息。使用命

       令

       rup

       ...,源码

       此处

       ...

       是要监视的

       linux/Unix

       服务器的

       IP

       ，如果该命令返回相关的源码验证QQ密码源码

       统计信息。则表示已经配置并且激活了

       rstatd

       守护进程；若未返回有意义的源码统计信息，或者出现一

       条错误报告，源码则表示

       rstatd

       守护进程尚未被配置或有问题。源码

       ②使用

       find

       命令

       #find / -name rpc.rstatd,源码

       该命令用于查找系统中是否存在

       rpc.rstatd

       文件，如果没有，源码说明系统没

       有安装

       rstatd

       守护程序。源码

       2

       ．

       linux

       需要下载

       3

       个包：

       （

       1

       ）

       rpc.rstatd-4.0.1.tar.gz

       （

       2

       ）

       rsh-0.-.i.rpm

       （

       3

       ）

       rsh-server-0.-.i.rpm

       3

       ．下载并安装

       rstatd

       如果服务器上没有安装

       rstatd

       程序（一般来说

       LINUX

       都没有安装）

       ，源码任务发布 php源码需要下载一个包才有这个服

       务

       ,源码

       包

       名

       字

       是

       rpc.rstatd-4.0.1.tar.gz.

       这

       是

       一

       个

       源

       码

       ,

       需

       要

       编

       译

       ,

       下

       载

       并

       安

       装

       rstatd

       （

       可

       以

       在

       municate with the portmapper on host '...'.

       RPC: RPC call failed.

       RPC-TCP: recv()/recvfrom() failed.

       RPC-TCP: Timeout reached. (entry point: CFactory::Initialize). [MsgId: MMSG-]

       检查原因，发现是源码

       Linux

       系统中的防火墙开启了并且阻挡了

       LoadRunner

       监控

       Linux

       系统的资源，

       因此要将防火墙关闭。https通信源码

       关闭防火墙：

       [root@localhost ~]# /etc/init.d/iptables stop;

       三、监控

       UNIX

       lr

       监控

       UNIX

       UNIX

       先启动一

       rstatd

       服务

       以下是在

       IBM AIX

       系统中启动

       rstatd

       服务的方法：

       1

       ．使用

       telnet

       以

       root

       用户的身份登录入

       AIX

       系统

       2

       ．在命令行提示符下输入：

       vi /etc/inetd.conf

       3

       ．查找

       rstatd

       ，找到

       #rstatd

       sunrpc_udp

       udp

       wait

       root /usr/sbin/rpc.rstatd rstatd 1-3

       4

       、蜘蛛爬行记录源码将

       #

       去掉

       5

       、

       :wq

       保存修改结果

       6

       、命令提示符下输入：

       refresh

       –

       s inetd

       重新启动服务。

       这样使用

       loadrunner

       就可以监视

       AIX

       系统的性能情况了。

       注：在

       HP UNIX

       系统上编辑完

       inetd.conf

       后，重启

       inetd

       服务需要输入

       inetd -c

       UNIX

       上也可以用

       rup

       命令查看

       rstatd

       程序是否被配置并激活

       若

       rstatd

       程序已经运行，

       重启时，

       先查看进程

       ps -ef |grep inet

       然后杀掉进程，

       再

       refresh

       –

       s inetd

       进行重启。

如何获取queueviewmbean对象

       org.apache.activemq.broker.jmx

       æŽ¥å£queueviewmbean

       All Superinterfaces:

       destinationviewmbean

       All Known Implementing Classes:

       queueview

       å…¬å…±æŽ¥å£queueviewmbean

       å»¶ä¼¸

       destinationviewmbean

       Method Summary

       int copymatchingmessagesto（字符串选择器，字符串destinationName）

       å°†ç»™å®šçš„选择器匹配的消息

       int copymatchingmessagesto（字符串选择器，字符串destinationName， int maximummessages）

       å°†ç»™å®šçš„选择到匹配的消息的最大数目 匹配的消息

       å¸ƒå°” copymessageto（字符串messageId，字符串destinationName）

       å¤åˆ¶ä¸€ä¸ªç»™å®šçš„消息到另一个目的地。

       int cursorsize（）

       å¸ƒå°” doescursorhavemessagesbuffered（）

       å¸ƒå°” doescursorhavespace（）

       é•¿ getcursormemoryusage（）

       int getcursorpercentusage（）

        复合数据 GetMessage（字符串messageId）

       æ£€ç´¢ä»Žç›®æ ‡é˜Ÿåˆ—的消息。

        地图<字符串，字符串> getmessagegroups（）

        字符串 getmessagegrouptype（）

       å¸ƒå°” iscacheenabled（）

       å¸ƒå°” iscursorfull（）

       int movematchingmessagesto（字符串选择器，字符串destinationName）

       å°†ç»™å®šçš„选择器匹配的消息

       int movematchingmessagesto（字符串选择器，字符串destinationName， int maximummessages）

       å°†ç»™å®šçš„选择到匹配的消息的最大数目 匹配的消息

       å¸ƒå°” movemessageto（字符串messageId，字符串destinationName）

       å°†é‚®ä»¶ç§»åŠ¨åˆ°å¦ä¸€ä¸ªç›®çš„地。

       æ— æ•ˆ 净化（）

       åˆ é™¤æ‰€æœ‰é˜Ÿåˆ—中的消息。

       æ— æ•ˆ removeallmessagegroups（）

       åˆ é™¤æ‰€æœ‰çš„信息会在消费者群体平衡所有消息组

       int removematchingmessages（字符串选择器）

       åˆ é™¤ç»™å®šé€‰æ‹©å™¨åŒ¹é…çš„消息

       int removematchingmessages（字符串选择器， int maximummessages）

       åˆ é™¤ç»™å®šçš„选择到匹配的消息的最大数目 匹配的消息

       å¸ƒå°” removemessage（字符串messageId）

       ä»Žé˜Ÿåˆ—中删除一个消息。

       æ— æ•ˆ removemessagegroup（字符串组名）

       åˆ é™¤é‚®ä»¶ç»„具有平衡群体的影响

       å¸ƒå°” retrymessage（字符串messageId）

       ç§»åŠ¨æ¶ˆæ¯å›žåˆ°åŽŸæ¥çš„目的地

       int retrymessages（）

       é‡è¯•ä¿¡æ¯å‘送到死信队列

       ä»Žç•Œé¢org.apache.activemq.broker.jmx继承的方法。destinationviewmbean

       æµè§ˆï¼Œæµè§ˆï¼Œbrowseastable，browseastable，browsemessages，browsemessages，getaverageblockedtime，getaverageenqueuetime，getaveragemessagesize，getblockedproducerwarninginterval，getblockedsends，getconsumercount，getdequeuecount，getdispatchcount，getenqueuecount，getexpiredcount，getinflightcount，getmaxauditdepth，getmaxenqueuetime，getmaxmessagesize，getmaxpagesize，getmaxproducerstoaudit，getmemorylimit，getmemorypercentusage，getmemoryusagebytecount，getmemoryusageportion，getminenqueuetime，getminmessagesize，getName，getoptions，getproducercount，getqueuesize，getslowconsumerstrategy，getsubscriptions，gettotalblockedtime，isalwaysretroactive，isdlq，isprioritizedmessages，isproducerflowcontrol，isusecache，resetstatistics，sendtextmessage，sendtextmessage，sendtextmessage，sendtextmessage，sendtextmessagewithproperties，setalwaysretroactive，setblockedproducerwarninginterval，setmaxauditdepth，setmaxpagesize，setmaxproducerstoaudit，setmemorylimit，setmemoryusageportion，setproducerflowcontrol，setusecache

       Method Detail

       GetMessage

       å¤åˆæ•°æ® GetMessage（字符串

        messageId）opendataexception

       æ£€ç´¢ä»Žç›®æ ‡é˜Ÿåˆ—的消息。

       å‚æ•°:

       messageId

       ä¿¡æ¯çš„检索消息ID

       é€€è´§

       ä¸€ç§å¤åˆæ•°æ®å¯¹è±¡æ˜¯ä¸€ä¸ªJMX版本信息

       Throws:

       opendataexception

       removemessage

       å¸ƒå°”removemessage（字符串

        messageId）例外

       ä»Žé˜Ÿåˆ—中删除一个消息。如果消息已经 派遣到另一个消费者，消息不能被删除，这 方法将返回false。

       å‚æ•°:

       messageId

       â€”

       é€€è´§

       å¦‚果消息被发现可以成功删除。

       Throws:

       ä¾‹å¤–

       removematchingmessages

       intremovematchingmessages（字符串

       é€‰æ‹©å™¨ï¼‰ä¾‹å¤–

       åˆ é™¤ç»™å®š

Python多进程系列之Queue类

       åœ¨ä½¿ç”¨å¤šè¿›ç¨‹çš„过程中，最好不要使用共享资源。普通的全局变量是不能被子进程所共享的，只有通过multiprocessing组件构造的数据结构可以被共享。

       Queue是用来创建进程间资源共享的队列的类，使用Queue可以达到多进程间数据传递的功能。但是Queue只能在Process类中使用，不能再Pool类中使用。

1.基本介绍1.1 构造方法

       Queue([maxsize])

       maxsize是队列中允许最大项数，省略则为无限大队列

1.2 实例方法

       put():用来在队列中插入数据。该方法有2个可选参数：blocked和timeout。若blocked的值为True(默认值)且timeout的值大于0，该方法会阻塞timeout的时间，直到该队列有剩余的空间。超时抛出Queue.Full异常。若blocked的值为False,且Queue已满，则会立即抛出Queue.Full异常

       get():从队列获取一个元素并且删除该元素，类似于列表的pop()方法。该方法也有2个可选参数：blocked和timeout。若blocked的值为True(默认值)且timeout的值大于0，会在timeout的时间内没有获取到抛出Queue.Empty异常。若blocked的值为False,且队列有一个元素可用，则返回该元素。若blocked的值为False,且队列为空则抛出Queue.Empty异常。设置blocked的值为True或者参数全部置空可以防止Queue在empty的时候抛出异常。

       put_nowait():同put(blcoked=False)

       get_nowait():同get(blcoked=False)

       empty():判断队列是否为空。但是该方法在队列为空返回True时不可靠，比如返回True时put()方法插入了新的数据。

       full():判断队列是否已满，该方法也不可靠，比如返回True时get()方法取走了数据。

       qsize():返回队列中目前元素的数量，也不可靠，原因同empty()和full()

2.使用示例frommultiprocessingimportQueue,Processimportosimporttimeimportrandomdefwrite(q):print(f'Processtowrite:{ os.getpid()}')forvalueinrange(5):print(f'put{ value}toqueue......')q.put(value)time.sleep(random.random())defread(q):print(f'Processtoread:{ os.getpid()}')whileTrue:value=q.get(True)print(f'get{ value}fromqueue......')if__name__=='__main__':q=Queue()pw=Process(target=write,args=(q,))pr=Process(target=read,args=(q,))pw.start()pr.start()pw.join()pr.terminate()

       result:

Processtowrite:put0toqueue......Processtoread:get0fromqueue......put1toqueue......get1fromqueue......put2toqueue......get2fromqueue......put3toqueue......get3fromqueue......put4toqueue......get4fromqueue......