本地消息队列：我们在下载好的activemq文件夹下的config文件夹下，找到activemq.bat文件运行，浏览器访问http://activemq-host:8161/admin。
activemq-host是启动机器的ip地址，8161是activemq的默认端口号，默认用户名和密码是admin。会进入一下界面：
20161107162440331.png
当然，这是本地的消息队列，访问，我们启动之后也可以通过jdk自带的jconsole来监控。这里重点介绍怎样远程监控activemq。
远程监控activemq：这里涉及到JMX的概念，网上我也搜了很多，但是特别官网，我也看的不是很明白，这里大家知道由Java开发的程序，一般都是jmx来监控就可以了，当然，activemq也是通过Jmx来监控的。这里首先我们来配置一些东西。
1.在你下载activemq文件夹下的config中，找到activemq.xml，在broker节点增加useJmx="true"
20161107164841436.png
2.在managementContext节点更改成下面的截图的样子（这里我直接截图了，增加的东西不多，我就不把能复制的放进来了，自己敲敲，熟悉一下~）
20161107165108593.png
3.在你activemq文件夹下的bin找到activemq（${active_home}/bin/activemq），找到下面截图中出出现的代码，应该是注释掉的，解除注释就行了，我下载的版本是5.13.4，有的没有下面的代码，不知道是什么原因，这个弄明白之后，会再更新。
代码版(这个可以直接粘贴过去)：
ACTIVEMQ_SUNJMX_START="-Dcom.sun.management.jmxremote.port=11099"
ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote.password.file=${ACTIVEMQ_CONF}/jmx.password"
ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote.access.file=${ACTIVEMQ_CONF}/jmx.access"
ACTIVEMQ_SUNJMX_START="$ACTIVEMQ_SUNJMX_START -Dcom.sun.management.jmxremote.ssl=false"
截图版：
20161107170019130.png
4.在Linux上进入${active_home}/bin中执行chmod 655 activemq用来获取active的权限，我们解压activemq之后，发现在bin的activemq是灰色，不能正常启动就执行activemq restart这条命令。执行完这条命令之后，会变成绿色。
20161107170804155.png
然后执行chmod 400 ${activemq_home}/conf/jmx. 意思是设置当前用户只读，其他用户没有权限。
5.接下来在${activemq_home}/bin下执行activemq start或者activemq restart，一般在前面加sudo，一般用户没权限。
activemq stop来停止或者用ps显示当前运行的activemq的线程号，然后kill即可。
好了，接下来，我们来用jdk自带的jconsole来检测一下。
20161108095106364.png
用户名：admin
密码：activemq
这里有可能出现还远程不上的情况：这里有我尝试了下有两种解决办法
- 关闭远程服务器上的防火墙(当然，这个不推荐，容易被黑客攻击)
- 修改hosts文件，添加远程实际的Ip地址
20161108095457038.png
当然，我们在实际项目中可能不单单登录activemq的web console或者jconsole来实现监控，我在项目中就是用java程序来实现跟web console一样的页面展示的形式。接下来引用我实际项目中的代码。
controller
String surl = Constant.MQ_URL;
String userName = Constant.MQ_USERNAME;
String userPwd = Constant.MQ_USERPWD;
Map<String, String[]> env = new HashMap<>();
String[] credentials = {userName, userPwd};
env.put(JMXConnector.CREDENTIALS, credentials);
JMXServiceURL url = new JMXServiceURL(surl);
JMXConnector jmxc = JMXConnectorFactory.connect(url, env);
// JMXConnector jmxc = JMXConnectorFactory.connect(url, null);
MBeanServerConnection mbsc = jmxc.getMBeanServerConnection();
ObjectName mbeanName = new ObjectName("org.apache.activemq:brokerName=localhost,type=Broker");
//MBeanInfo info = mbsc.getMBeanInfo(mbeanName);
BrokerViewMBean mbean =(BrokerViewMBean) MBeanServerInvocationHandler.newProxyInstance(mbsc, mbeanName, BrokerViewMBean.class, true);
List<MqModel> mqList = new ArrayList<MqModel>();
OrganizationService organizationService = (OrganizationService) SpringBeanUtil.getBean("organizationService");
for (ObjectName na : mbean.getQueues()) {
QueueViewMBean queueBean = (QueueViewMBean)MBeanServerInvocationHandler.newProxyInstance(mbsc, na, QueueViewMBean.class, true);
MqModel mq = new MqModel();
Organization organ = organizationService.getOrganization(queueBean.getName());
if(organ!=null){
mq.setName(organ.getOrgName());
}else{
mq.setName(queueBean.getName());
}
mq.setQueueSize(queueBean.getQueueSize());
mq.setConsumerCount(queueBean.getConsumerCount());
mq.setDequeueCount(queueBean.getDequeueCount());
mq.setEnqueueCount(queueBean.getEnqueueCount());
queueBean.getEnqueueCount();
mqList.add(mq);
}
（上面的代码中获取实际数据通过queueBean.__来获取，这里我用一个model来接收了。下面会引入model的代码）
Constant:
public static final String MQ_URL = properties.getProperty("mq.url");//获取mq远程链接地址
public static final String MQ_USERNAME = properties.getProperty("mq.userName");//mq用户名
public static final String MQ_USERPWD = properties.getProperty("mq.userPwd");//mq密码
Model:
/**
* 这里自定义一个Model来接收队列的信息
* @author LY
* @date 2016-08-10 11:11
*/
public class MqModel {
private String name;//队列的名称
private Long queueSize;//队列中剩余的消息数
private Long consumerCount;//消费者数
private Long enqueueCount;//进入队列的总数量
private Long dequeueCount;//出队列的数量
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Long getQueueSize() {
return queueSize;
}
public void setQueueSize(Long queueSize) {
this.queueSize = queueSize;
}
public Long getConsumerCount() {
return consumerCount;
}
public void setConsumerCount(Long consumerCount) {
this.consumerCount = consumerCount;
}
public Long getDequeueCount() {
return dequeueCount;
}
public void setDequeueCount(Long dequeueCount) {
this.dequeueCount = dequeueCount;
}
public Long getEnqueueCount() {
return enqueueCount;
}
public void setEnqueueCount(Long enqueueCount) {
this.enqueueCount = enqueueCount;
}
}
application.properties:
#消息队列服务配置
my.url = service:jmx:rmi:///jndi/rmi://198.9.4.167:11099/jmxrmi
mq.userName = admin
mq.userPwd = activemq
我遇到的问题：在刚接到这个需求的时候，我搜了很多，把activemq的远程配置第一步完成之后，发现用代码在java程序中控制台总是报权限的错误，不知道为什么，配置也配置好了，后来在stackoverflow看到其他程序猿也遇到这个问题，我看他们怎么实现，修改了下我的代码，就可以了。controller注释的部分是我以前的代码。
Map<String, String[]> env = new HashMap<>();
String[] credentials = {userName, userPwd};
env.put(JMXConnector.CREDENTIALS, credentials);
我发现必须把activemq远程的用户名和密码放在map才可以~~~~
网友评论