精华内容
下载资源
问答
  • 赋权 通过端口15672登录进后台之后,选择“admin”菜单,然后选择创建的“admin”用户,进去单击“Set permission”即可 五、如果同一台服务器上存在了activemq,需要改端口 1.在rabbitmq的etc下创建文件 vim ...

    一、安装依赖环境

    yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make gcc gcc-c++ kernel-devel m4 ncurses-devel

    二、安装erlang

    1.下载源码

    wget http://erlang.org/download/otp_src_21.0.tar.gz

    2.解压源码

    tar xvf otp_src_21.0.tar.gz

    3.进入解压后的目录

    cd otp_src_21.0

    4.配置安装路径

    ./configure --prefix=/usr/local/erlang --with-ssl -enable-threads -enable-smmp-support -enable-kernel-poll --enable-hipe --without-javac

    5.编译安装

    make && make install

    6.配置环境变量

    vim /etc/profile

    在最后面加上

    export PATH=$PATH:/usr/local/erlang/bin

    保存退出后执行下面语句使之生效

    source /etc/profile

    7.验证

    输入“erl”。如果能显示erlang的版本等信息表示安装成功。

    三、安装RabbitMQ

    1.下载源码,rabbitmq-server-generic-unix-3.7.8.tar.xz

    wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.7.8/rabbitmq-server-generic-unix-3.7.8.tar.xz

    2.解压文件

    xz -d rabbitmq-server-generic-unix-3.7.8.tar.xz

    tar -xvf rabbitmq-server-generic-unix-3.7.8.tar

    解压后的文件名是:

    rabbitmq_server-3.7.8

    3.进入rabbitmq_server-3.6.14直接运行

    ./sbin/rabbitmq-server start

    四、管理

    1.启动

    ./sbin/rabbitmq-server start

    2.启动管理插件

    ./rabbitmq-plugins enable rabbitmq_management

    3.添加用户并分配权限

    ./rabbitmqctl add_user admin admin

    ./rabbitmqctl set_user_tags admin administrator

    4.停止

    ./rabbitmqctl stop

    5.查看端口占用情况

    netstat -lnp|grep 5672

    6.赋权

    通过端口15672登录进后台之后,选择“admin”菜单,然后选择创建的“admin”用户,进去单击“Set permission”即可

    五、如果同一台服务器上存在了activemq,需要改端口

    1.在rabbitmq的etc下创建文件

    vim rabbitmq/etc/rabbitmq/rabbitmq.conf

    2.添加你的ip和端口最后重新启动rabbitmq服务即可

    listeners.tcp.default = ip:6573

    六、权限设置

    建了vhost忘记给权限到用户

    rabbitmqctl set_permissions -p "/" username ".*" ".*" ".*"

    给kyoxue分配test名的vhost权限

    rabbitmqctl set_permissions -p "test" kyoxue ".*" ".*" ".*"

    参考网站:https://www.cnblogs.com/duanjt/p/10042862.html#undefined

    展开全文
  • KacieHouser8iprabbitmq我有一个方框A,它上面有一个用户监听Rabbit MQ服务器我有一个盒子B,它会向收听者发布一条消息因此,只要在方框A和我的所有这一切启动Rabbit MQ服务器w /默认值它就可以正常工作.端口5672上的...

    KacieHouser

    8

    ip

    rabbitmq

    我有一个方框A,它上面有一个用户监听Rabbit MQ服务器

    我有一个盒子B,它会向收听者发布一条消息

    因此,只要在方框A和我的所有这一切启动Rabbit MQ服务器w /默认值它就可以正常工作.

    端口5672上的默认值为host = 127.0.0.1,但是当我telnet box.a.ip.addy 5672从Box BI获取时:

    Trying box.a.ip.addy...

    telnet: connect to address box.a.ip.addy: No route to host

    telnet: Unable to connect to remote host: No route to host

    端口22上的telnet很好,我可以从Box B ssh到Box A.

    所以我假设我需要更改RabbitMQ服务器使用的ip我发现这个:http://www.rabbitmq.com/configure.html我现在在文档说要使用的位置有一个配置文件,名称rabbitmq.config,它包含:

    [

    {rabbit, [{tcp_listeners, {"box.a.ip.addy", 5672}}]}

    ].

    所以我停止了服务器,并再次启动了RabbitMQ服务器.它失败了.以下是错误日志中的错误.这有点过头了.(事实上​​大部分都是)

    =ERROR REPORT==== 23-Aug-2011::14:49:36 ===

    FAILED

    Reason: {{case_clause,{{"box.a.ip.addy",5672}}},

    [{rabbit_networking,'-boot_tcp/0-lc$^0/1-0-',1},

    {rabbit_networking,boot_tcp,0},

    {rabbit_networking,boot,0},

    {rabbit,'-run_boot_step/1-lc$^1/1-1-',1},

    {rabbit,run_boot_step,1},

    {rabbit,'-start/2-lc$^0/1-0-',1},

    {rabbit,start,2},

    {application_master,start_it_old,4}]}

    =INFO REPORT==== 23-Aug-2011::14:49:37 ===

    application: rabbit

    exited: {bad_return,{{rabbit,start,[normal,[]]},

    {'EXIT',{rabbit,failure_during_boot}}}}

    type: permanent

    这里还有一些来自启动日志:

    Erlang has closed

    Error: {node_start_failed,normal}

    ^M

    Crash dump was written to: erl_crash.dump^M

    Kernel pid terminated (application_controller) ({application_start_failure,rabbit,{bad_return,{{rabbit,start,[normal,[]]},{'EXIT',{rabbit,failure_during_boot}}}}})^M

    请帮忙

    展开全文
  • 消息队列(Message Queue)简称为MQ,作为目前的主流中间件,在很多软件或程序中均会得到使用,测试人员在测试过程中会遇到涉及MQ的系统改造,因而需要利用JMeter实现消息队列数据的发送和接收,完成性能测试工作。...

    9b9f4302-9511-eb11-8da9-e4434bdf6706.png

    JMeter是性能测试中被普遍使用的一种工具,常用于压力测试。该工具具有丰富的扩展插件用以满足不同情况下性能测试的需求。消息队列(Message Queue)简称为MQ,作为目前的主流中间件,在很多软件或程序中均会得到使用,测试人员在测试过程中会遇到涉及MQ的系统改造,因而需要利用JMeter实现消息队列数据的发送和接收,完成性能测试工作。本文基于实际工作中遇到的项目情况,介绍了一种JMeter扩展插件Mqmeter的使用方法,完成消息队列的性能测试。

    1、引言

    消息队列是分布式系统中的重要组件,主要解决应用耦合,异步消息,流量削锋等问题,以实现高性能、高可用、可伸缩和最终一致性架构。作为大型分布式系统中不可缺少的中间件,目前使用较多的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ和RocketMQ等。

    JMeter作为Apache的开源性能测试工具,支持多种服务类型的测试;同时允许使用者对其进行二次开发扩展,以插件的形式满足JMeter无法提供的定制化需求,目前网络上包含有多种开源插件可供测试人员使用。

    本文结合实际测试工作中所遇到的消息队列测试需求,介绍了一种JMeter插件Mqmeter,该插件可用于在IMB MQ队列上放置和获取消息。它使用IP地址、端口号、用户名和密码通过服务器通道连接到MQ服务器。通过该插件,测试人员可以使用JMeter完成MQ的压力测试,通过该插件实现对MQ的多并发操作。

    2、环境准备

    JMeter的运行需要JAVA环境,Mqmeter插件源代码的编译需要Maven环境,本节将对Mqmeter插件使用过程中的运行环境部署加以详细的阐述。

    2.1 环境架构说明

    本文实际进行性能测试的架构如下,报文大概流向为:JMeter发送报文至小型机应用接口,小型机应该程序将消息报文写入MQ队列中,消息消费模块从MQ中获取并消费消息报文。

    9c9f4302-9511-eb11-8da9-e4434bdf6706.png

    2.2 环境配置

    JMeter运行需要Java环境,编译Java源代码形成jar包需要Maven,Maven运行也需要Java环境,具体JDK环境安装过程和Java环境变量配置不在此展开,如有需要可自行上网查询。

    2.2.1Maven安装

    Maven的下载地址:http://maven.apache.org/download.cgi,具体可根据已按安装的JDK版本选择相匹配的Maven版本下载,具体参考如下:

    9e9f4302-9511-eb11-8da9-e4434bdf6706.png

    不同操作系统对应的下载文件如下:

    a09f4302-9511-eb11-8da9-e4434bdf6706.png

    Maven下载到本地后默认安装即可,关键需要配置环境变量,本文使用的是Windows操作系统,以Windows下环境变量配置为例进行环境变量配置介绍。具体步骤如下;

    1)右键“计算机”,选择“属性>高级系统设置>环境变量,新建系统变量MAVEN_HOME,变量值:C:Mavenapache-maven-3.6.3(即安装目录)。如下:

    a19f4302-9511-eb11-8da9-e4434bdf6706.png

    2)编辑系统变量Path,添加变量值:;%MAVEN_HOME%bin。如下:

    a39f4302-9511-eb11-8da9-e4434bdf6706.png

    2.2.2Mqmeter插件安装

    JMeter是一款开源的性能测试工具,功能强大,可扩展接口丰富。现有的JMeter插件对MQ消息队列进行性能测试体验稍差,本文采用GitHub上一开源项目形成的JMeter插件执行MQ消息队列的性能测试。该插件具体安装步骤如下:

    1)Mqmeter源代码下载

    GitHub下载链接:http://github.com/JoseLuisSR/mqmeter,将Mqmeter源代码下载并解压至本机,指定路径存放。

    2)构建扩展包

    命令行模式进入本机Mqmeter源代码目录下,执行命令:mvn package。

    a59f4302-9511-eb11-8da9-e4434bdf6706.png

    该命令完成了Mqmeter源代码的编译,单元测试和打包。利用源码构建可执行Jar包,构建过程如下图所示:

    a69f4302-9511-eb11-8da9-e4434bdf6706.png

    构建成功后会在源代码目录下生成一个target文件夹,如下图所示:

    a89f4302-9511-eb11-8da9-e4434bdf6706.png

    该文件夹中包含可执行jar包:mqmeter-2.0.1.jar

    3)Mqmeter安装

    将上步中生成的mqmeter-2.0.1.jar放置到“$JMeter_HOME/lib/ext”路径下,如图所示,至此Mqmeter的环境准备工作基本完成。

    aa9f4302-9511-eb11-8da9-e4434bdf6706.png

    3、压测执行

    本节主要说明利用Mqmeter插件执行性能测试过程中JMeter的使用和MQ消息队列的性能监控。

    3.1 JMeter使用

    Mqmeter的环境准备完成后,就可以在JMeter中使用该Java取样器发送消息报文。步骤如下:

    1)进入JMeter安装目录apache-jmeter-5.0bin,双击jmeter.bat启动JMeter,添加线程组;

    ab9f4302-9511-eb11-8da9-e4434bdf6706.png

    2)在线程组中添加取样器,Mqmeter在取样器中名称为“Java Request”;

    ae9f4302-9511-eb11-8da9-e4434bdf6706.png

    3)根据测试内容对取样器中的必填参数进行填写;

    b09f4302-9511-eb11-8da9-e4434bdf6706.png

    上图中各参数所代表的含义在此稍加解释:

    mq_manager:MQ管理器名称,可以通过IBM WAS控制台获取。

    mq_queue_rqst:放置消息的队列名称,可以是本地消息队列也可以是远程队列。

    mq_queue_rsps:获取消息的队列名称,可以是本地消息队列也可以是远程队列,如果不想收到响应消息请将其置空。

    mq_correlate_rsps_msg:将响应消息与请求消息相关联,从MQ队列中获取新的消息。如果不想收到响应消息,将其置空。

    mq_wait_interval:设置get消息调用等待合适的消息到达的等待间隔。

    mq_hostname:运行MQ Server的主机名或IP地址。

    mq_port:MQ服务器侦听器的端口号。

    mq_channel:MQ服务器上的服务器通道名称。

    mq_user_id:连接到MQ服务器通道的用户ID。

    mq_user_password:连接到MQ服务器通道的用户密码。

    mq_encoding_message:消息的字符编码标准:对于EBCDIC,请输入Cp1047,ASCII只需输入ASCII。

    mq_message:消息内容。

    4)从上步中能够看出,为提现Mqmeter插件的强大功能,本文对java request的配置页中的变量都进行了参数化,能够实现向不同MQ队列、不同的消息管理器发送不同的消息内容。具体参数配置过程:添加配置元件(Config Element)>用户自定义参数(User Defined Variable),各个参数具体填写如下:

    b49f4302-9511-eb11-8da9-e4434bdf6706.png

    5)汇总报告、TPS监听器、响应时间、查看结果树配置完成后即可开始测试。

    至此性能测试发压机端的发压功能已部署完成。

    3.2 MQ性能监控

    MQ的性能测试过程中要不断查看MQ队列的深度,一是为了确保相关系统交易链路的可用性,二是定性的查看MQ本身的读写性能。而通过指令对MQ操作过于繁琐,本文将指令脚本化,大大节省了对MQ性能测试过程中的时间,也提高了效率。

    本文MQ消息队列安装在IBM AIX小型机上,常用MQ操作有启动消息队列管理器【runmqsc test1】、查看队列深度【dis ql(MSGMB_1)】,同时需要关注队列深度字段【CURDEPTH】随时间的变化,脚本化如下:

    b69f4302-9511-eb11-8da9-e4434bdf6706.png

    实时输出如下:

    b99f4302-9511-eb11-8da9-e4434bdf6706.png

    4、总结

    本文介绍了一种利用Mqmeter插件对MQ消息队列进行性能测试,并通过对UNIX指令脚本化实现对MQ的实时监控,详细介绍了Mqmeter从源代码生成JAR包,再到Jmeter使用该插件进行性能测试,希望能对从事MQ性能测试的同业人员有所帮助,同时本文还有诸多不足,诸如由于实际项目需求未介绍利用Mqmeter从消息队列取消息、未介绍量化性能的具体方法等等,后续如有实际项目需求会做进一步探索。

    展开全文
  • 1、MQ服务器崩溃调节:  今天具安卓前端反应, 从昨天下午开始线上服务器使用 电话号码登陆和 使用电话号码注册功能不能使用,   经过前端仔细排查怀疑是后端问题,之后经过与ios前端 确认, 定位为后端服务器...

    1、MQ服务器崩溃调节:   

              今天具安卓前端反应, 从昨天下午开始线上服务器使用 电话号码登陆和 使用电话号码注册功能不能使用,  

                    经过前端仔细排查怀疑是后端问题,之后经过与ios前端 确认, 定位为后端服务器问题。

              分析问题: 昨天下午之前未发生问题, 期间未改动过代码, 应该是服务器问题。 通过查询 硬盘占有量 cup占有率等 常规手段 没有定位到服务器异常。

                    之后考虑为数据库异常,因为安卓模拟器上返回信息为手机号未注册, 将本地代码数据库连接上 生产环境数据库, 和安卓前端进行联调,

                    发现返回值确实异常,未从数据库中查到信息, sql语句拷贝到navicat中执行, sql语句无吴。 近一步定位此问题, 发现是在安卓模拟器上

                    上传的参数有误,不能从数据库中查找到, 改正参数传入, 后端能从数据库中拿到数据,但是模拟器陷入了无限等待。

              分析上述情况: 在后端代码中发生了阻塞, 于是逐步排查。

                    发现在调用MQ消息发送语句的时候发生阻塞。注释该代码,运行正常  ,确定该代码有误。将 mq连接地址改为测试 MQ, 可以运行 

                     于是,定位到 服务器 的 MQ 异常,此异常符合 具体情况描述。

              打开MQ, 发现是其中的存储文件太多,疑似将 MQ服务器撑爆。 删除部分 log文件,运行发现 关闭 MQ服务器(以下使用 服务器代称),发现关闭失败。

                     随通过端口查询进程id, 并kill 这些进程。  出现问题: 服务器不能进行启动。

                    之后通过网上查询 并通过控制台查看具体信息, 发现类似方法: activemq.xml文件中的 0.0.0.0 改为 127.0.0.1 ,再次启动 未果  。

                    其它类似方法也有一一尝试, 均告失败。

            通过博客:https://blog.csdn.net/xiaobao5214/article/details/52222655 ,其中信息与我们的基本类似, 其解决方法 要求 重置服务器名称(linux服务器,要求不能有下划线和特使字符),

                     考虑生产环境情况复杂, 不敢随意尝试该方法 。

            最后定下方案: 尝试自己删除部分 data目录下的文件,并将 在前面尝试过程中的所有配置更改 回复原来面目。如果再不行 就卸载重装 一个服务器。

            再删除了 db.data之后, 发现服务器正常启动, 之后运行项目, 并监听服务器,发现其能够正常接收 响应消息。 

    转载于:https://www.cnblogs.com/soficircle/p/8929186.html

    展开全文
  • MQ服务器的配置

    千次阅读 2008-07-01 16:20:00
    MQ服务器A的配置[MQ安装目录]/conf/activemq.xml (只列出需要修改的两处) --> 将上面的默认设置修改成下面红色的新设置--> uri="ssl://localhost:61617"/> uri="stomp://local
  • 很重要MQ传输培训异常问题及解决方法 MQSeries部分(续) 在连接一切正常的情况下不能从远端MQ服务器接收文件 可能的原因: 接收通道的序列号与远端MQ服务器发送通道序列号不一致 解决方法: 登录远端MQ服务器主机,...
  • 无法连接到MQ服务器的解决方法

    千次阅读 2012-08-03 14:03:58
    MQ服务器是装在本机上的,客户端也是自己写的小程序(XMS),在连接MQ队列管理器的时候,总是无法连接上(程序上连接到网络上其它MQ服务器则可以连接上),到事件查看器中,发现MQ有下面的错误日志。 ======...
  • MQ服务器端和客户端通信浅谈 1. WebSphere MQ的服务端的安装和配置 (1)创建名为venus.queue.manager的默认队列管理器。 在DOS窗口命令提示符下,输入以下命令: crtmqm -q venus.queue.manager (2)启动...
  • 基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通端口号的问题解决基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通端口...
  • 问题:在服务器A上部署MQ服务器后,部署成功通过本地可以正常访问。但是服务器B上的消费者连接不上MQ服务器(因为之前都是在单机上部署、调试都是没问题的),这种情况有可能是A服务器上MQ服务对应的接口被防火墙...
  • 这个例子的目的是建立可以实现消息传递的一对MQ服务器,它们分别基于NT和UNIX平台。 首先在NT端建一队列管理器 crtmqm –q QM_NT 启动队列管理器 strmqm QM_NT 运行MQ控制台命令 runmqsc QM_NT 创建死信队列 DEFINE ...
  • 最近一直在调试关于IBM MQ的接口,把相关的工作经验分享给大家,首先说一下前提:IBM MQ Server端在国外,给我们提供接口,包括: Ip地址、 端口、队列管理器、队列和服务器连接通道,我们这端是写.net App程序来...
  • 如果一台机器安装多个jboss服务器,就需要修改服务器端口号,否则各个服务器之间会有冲突。目前确认需要修改的配置如下一、vi $JBOSS_HOME/server/default/conf/jboss-service.xml 1、WebService端口 <...
  • MQ安装部署修改配置conf/broker.conf添加brokerIP1brokerIP1=192.168.0.1brokerIP1:配置broker所在服务器的ip地址,以便Name Server连接修改 runserver.sh 和 runbroker.shrunserver.shJAVA_OPT="${JAVA_OPT} -...
  • 邮件服务器 使用Swagger和Active MQ的Spring Boot Server。 概述 这是一个使用SpringBoot框架在Java中构建启用了swagger的服务器的示例。 与Active MQ集成,如 ... 在application.properties中更改默认端口
  • 本教程介绍了如何设置客户机与...要点: 本教程介绍了如何处理客户机 - 服务器安装,其中,客户机是安装了 WebSphere® MQ 客户机的第三方机器,而服务器是定义了队列管理器 QM_ORANGE 的机器。 您将通过创建
  • mq

    2017-08-08 23:34:13
    2:查看监听器是否启动:应用程序服务器 >ejbserver2 -通信-消息传递-消息侦听服务器-侦听器端口 应用程序服务器 > ejbserver2 > 消息侦听器服务 > 侦听器端口   INFOLISTENER jms/mqfactory jms/TOEDSMP  ...
  • MQ服务器上,用命令创建了队列管理器,并且创建了通道和监听器,并且保证监听器是在运行状态 代码如下: crtmqm QM strmqm QM endmqm -i QM dspmq runmqsc QM def ql(orderQueue) replace alter qmgr ccsid...
  • UDP服务器: sz.tencent.com 端口:8000 IP地址:219.133.49.171 =in  UDP服务器:sz2.tencent.com 端口:8000 IP地址:58.60.14.44 LcCN! D ~A UDP服务器:sz3.tencent.com 端口:8000 IP地址:219.133.60.32 v %...
  • JAVA连接IBM MQ

    万次阅读 热门讨论 2017-01-20 18:03:50
    服务器连接通道名称为 “SERVERCONN” 创建队列管理器进入IBM MQ Explorer 创建队列管理器 右键“队列管理器”–>“新建”–>”队列管理器…” 添加队列管理器名字 一直下一步到这个页面,设定监听端口,点击...
  • JAVA 调用MQ

    千次阅读 2015-06-18 14:19:01
    前提:MQ服务器端 创建队列管理器:QueueManager,队列:XML.IN,服务器连接通道:SYSTEM.ADMIN.SVRCONN ,监听器监听1414端口。 package mq; import com.ibm.mq.MQC; import com.ibm.mq.MQEnvironment; import ...
  • 开启15672端口的安全组 原文链接:http://blog.maptoface.com/post/163
  • 安装Rabbit MQ

    2016-12-27 09:28:00
    Rabbit MQ 是建立在强大的Erlang OTP平台上,因此安装Rabbit MQ的前提是安装Erlang。...默认安装的Rabbit MQ 监听端口是5672 激活Rabbit MQ's Management Plugin 使用Rabbit MQ 管理插件,可以更好的可视化方式...
  • 我们在启动JBoss时,经常会遇到的问题就是端口被占用。 往往会出现以下信息: java.rmi.server.ExportException: Port already in use: 1098;nested exception is: java.net.BindException: Address already in ...
  • 基于腾讯云服务器搭建的rabbitmq无法访问管理页面,也telnet不通端口号的问题解决一、搭建rabbitmq创建docker-compose.yml在腾讯云中开启安全组二、问题描述三、问题排查1. 检查防火墙2. 查看端口监听3. 检查安全组...
  • WebSphere® MQ uses two different types of channels: A message channel, which is a unidirectional communications link between two queue managers. WebSphere MQ uses message channels to transfer mes...
  • WebSphere MQ使用

    千次阅读 2017-04-16 11:09:52
    根据项目需求,我们需要用到MQ集成到项目里,以下是我用客户端,简单搭建一个服务器连接通道。在此之前,如果你对MQ一无所知,我建议先仔细阅读以下入门的文章。首先,安装好客户端,在MQ Explorer中的左侧的导航的...
  • IBM MQ8.0配置

    2019-09-21 04:23:05
    因为工作需要使用MQ Server,使用Hyper-V安装的win7操作系统作为载体来搭建MQ环境。 经过不断下一步,我们安装好了MQ。然后开始配置: ...MQ用户名:fromsilence(注:需在MQ服务器所在宿主机win7系...

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 17,889
精华内容 7,155
关键字:

mq的服务器端口