activemq + jaxa +tomcat

ActiveMQ利用Ajax使用轮询机制去获取服务器的信息，而不是使用服务器推送方式,当指定
发送队列后，MessageListenerServlet就会监听这个队列。（自己理解）
首先第一步：配置tomcat
<Resource name="jms/ConnectionFactory"
auth="Container"
type="org.apache.activemq.ActiveMQConnectionFactory"
description="JMS Connection Factory"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
brokerURL="tcp://localhost:61616"
brokerName="LocalActiveMQBroker" />

将jar包放入到tomcat的lib包下,jar包如下：
activemq-web-5.4.1.jar
activemq-web-5.5.1.jar
geronimo-j2ee-management_1.1_spec-1.0.1.jar
geronimo-jms_1.1_spec-1.1.1.jar
geronimo-jta_1.0.1B_spec-1.0.1.jar
然后配置web.xml
<display-name>activemq of ajax</display-name>
<description>activemq的ajax应用</description>
<servlet>
<servlet-name>activemq</servlet-name>
<servlet-class>org.apache.activemq.web.AjaxServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>activemq</servlet-name>
<url-pattern>/amq/*</url-pattern>
<load-on-startup>1</load-on-startup>
</servlet-mapping>
<filter>
<filter-name>session</filter-name>
<filter-class>org.eclipse.jetty.continuation.ContinuationFilter
</filter-class>
</filter>

<filter-mapping>
<filter-name>session</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>

<listener>
<listener-class>org.apache.activemq.web.SessionListener
</listener-class>
</listener>

<filter>
<filter-name>SetCharacterEncoding</filter-name>
<filter-class>org.springframework.web.filter.CharacterEncodingFilter
</filter-class>
<init-param>
<param-name>encoding</param-name>
<param-value>utf-8</param-value>
</init-param>
<init-param>
<param-name>forceEncoding</param-name>
<param-value>true</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>SetCharacterEncoding</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
<context-param>
<param-name>org.apache.activemq.brokerURL</param-name>
<param-value>tcp://localhost:61616</param-value>
</context-param>

index.jsp页面代码如下：

<%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Activemq of Ajax test</title>
<link rel="stylesheet" type="text/css" href="./css/easyui.css">
<link rel="stylesheet" type="text/css" href="./css/demo.css">
<link rel="stylesheet" type="text/css" href="./css/icon.css">
<link rel="stylesheet" type="text/css" href="./css/slider.css">
<link rel="stylesheet" type="text/css" href="./css/messager.css">
<link rel="stylesheet" type="text/css" href="./css/layout.css">
<script type="text/javascript" src="./js/jquery-1.8.0.min.js"></script>
<script type="text/javascript" src="./js/amq_jquery_adapter.js"></script>
<script type="text/javascript" src="./js/amq.js"></script>
<script type="text/javascript" src="./js/jquery.easyui.min.js"></script>
<script type="text/javascript" src="./js/jquery.messager.js"></script>
<script type="text/javascript">
var amq = org.activemq.Amq;
amq.init({
//请求的url，axjaservlet会过滤以amq*所有的请求
uri : 'http://localhost:8089/activemq_web/amq',
logging : true,
timeout : 20//配置轮询的时间
});
var des = "queue://MY.NAME";//指定的发送队列名称
var queue = amq.getMessageQueue;
var myHandler = {
//回调函数，返回响应的结果
rcvMessage : function(message) {
//alert("received from handler " + message.data);
alert(message.data);
slide(message.data);
}
};
amq.addListener('list', des, myHandler.rcvMessage);
function getRecords() {
//获取文本框的内容作为发送的文本消息
var myMessage = document.getElementById("num").value;
//alert("message content=" + myMessage)
amq.sendMessage(des, myMessage);//发送消息的方法
//如果配置成功的话，这里会最后打印
alert("received " + myMessage);
}
//这个是easyui的插件，可以百度查找
function slide(msg) {
$.messager.show({
title : '消息推送',
msg : msg,
timeout : 5000,
showType : 'slide'
});
}
</script>
</head>
<body>
<div class="demo-info">
<div class="demo-tip icon-tip"></div>
<div>点击下面的滑动</div>
</div>
<div style="margin: 10px 0;">
<a href="#" class="easyui-linkbutton" οnclick="slide()">滑动</a>
</div>
<form action="message/FOO/BAR" method="post">
<p>
<label for="destination">Destination name</label> <input type="text"
name="destination" value="MY.NAME" />
</p>
<p>
<label for="type">Destination Type: </label> <select name="type">
<option selected value="queue">Queue</option>
<option type" value="topic">Topic</option>
</select>
</p>
<p>
<textarea name="body" rows="30" cols="20">
Enter some text here for the message body...
</textarea>
</p>
<p>
<input type="submit" value="Send" /> <input type="reset" />
</p>
</form>
<input type="TEXT" id="num" />

准备好这些以后，可以写一个服务端代码测试，如下：
package com.activemq;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.ActiveMQSession;

public class Producer {

public static void main(String[] args) throws JMSException {

// 获取 ConnectionFactory
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
"tcp://localhost:61616");

// 创建 Connection
Connection connection = connectionFactory.createConnection();
connection.start();

// 创建 Session
ActiveMQSession session = (ActiveMQSession) connection.createSession(
false, Session.AUTO_ACKNOWLEDGE);

// 创建 Destination
Destination destination = session.createQueue("MY.NAME");

// 创建 Producer
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);// 设置为非持久性
// 设置持久性的话，文件也可以先缓存下来，接收端离线再连接也可以收到文件
// 构造 BlobMessage，用来传输文件
TextMessage blobMessage = session.createTextMessage();
blobMessage.setText("askdhas d啊哈登记卡上的");
//blobMessage.setStringProperty("text", "<?test message?>");
// 7. 发送文件
producer.send(blobMessage);
System.out.println("发送完毕！！");
producer.close();
session.close();
connection.close(); // 不关闭 Connection, 程序则不退出
}

}

activemq + jaxa +tomcat相关推荐

ActiveMQ学习笔记（21）----ActiveMQ集成Tomcat
1. 监控和管理Broker Web Console 方式:直接访问ActiveMQ的管理页面:http://localhost:8161/admin,默认的用户名和密码是admin/admin.具体 ...
安装activemq或者tomcat等启动时报错
问题描述: 在编写shell脚本安装mq和tomcat的时候,到了启动那一步出现了报错.报错内容如下: INFO: Loading '/opt/apache-activemq-5.13.2//bin/ ...
ActiveMQ简单介绍+简单实例
本文出自:http://www.open-open.com/lib/view/open1388994166156.html 1. JMS基本概念 JMS(Java Message Servi ...
Apache ActiveMQ教程
一.特性及优势1.实现JMS1.1规范,支持J2EE1.4以上2.可运行于任何jvm和大部分web容器(ActiveMQ works great in any JVM)3.支持多种语言客户端(java ...
linux设置activemq开机启动,Activemq(centos7)开机自启动服务
编辑服务文件 vi /etc/init.d/activemq 文件内容如下 #!/bin/bash # chkconfig: 2345 10 90 # description: activemq .. ...
tomcat启动项目时一直卡住无反应的解决方案
关于tomcat启动项目时一直卡住无反应的场景之一: 最近碰到一次项目启动半天没反应,也不报错,项目在其它电脑上能正常启动运行.日志中有时候会报数据库连接超时,有时候会报类似于接连池问题. Cause ...
安排，ActiveMQ RabbitMQ RokcetMQ 消息队列中间件视频教程
来源: 来自网络,如侵权请告知博主删除????. 仅学习使用,请勿用于其他- 最近有小伙伴管我要 mq相关的视频,那我就直接3个Q都给大家发了,既然要了,记得看哦〜大家需要什么资源可以给我提,每周都 ...
java-大数据-精品课程目录(超级全)
网上看到的一个目录,可以通过对应视频名称网上找找资源第一章:java精品课程目录大全 1.亿级流量电商详情页系统的大型高并发与高可用缓存架构实战 1课程介绍以及高并发高可用复杂系统中的缓存架构有哪些 ...
[教程]Windows下使用Ladon批量爆破SSH弱口令
前言对于Linux操作系统来说,一般通过VNC.Teamviewer和SSH等工具来进行远程管理,SSH是 Secure Shell的缩写,由IETF的网络小组(Network Working Gr ...

activemq + jaxa +tomcat

activemq + jaxa +tomcat相关推荐

最新文章

热门文章