Advertisement

性能测试-Locust Stomp client

阅读量:

性能测试 - Locust Stomp client

Max.Bai

2018年2月

1. 需要安装stomp

stomp 协议能够实现与 activemq 的连接,并且还支持与其他系统进行通信。

复制代码
    pip install stomp.py
    

实现方案与技术细节

具体实施步骤在此省略,直接提供代码示例,该代码用于向ActiveMQ队列发送消息。

如需进一步了解详细内容,请参阅到这里

复制代码
 import time

    
 import random
    
 import stomp
    
 from locust import Locust, TaskSet, events, task
    
  
    
  
    
  
    
 class StompClient(object):
    
     def __init__(self, host, port):
    
     self.conn = stomp.Connection10([(host, port)])
    
  
    
     def __del__(self):
    
     if self.conn:
    
         print "disconnect.

全部评论 (0)

还没有任何评论哟~