六狼论坛

 找回密码
 立即注册

QQ登录

只需一步,快速开始

新浪微博账号登陆

只需一步,快速开始

搜索
查看: 40|回复: 0

ActiveMQ使用AjaxServlet来实现ajax推

[复制链接]

升级  20%

2

主题

2

主题

2

主题

童生

Rank: 1

积分
10
 楼主| 发表于 2013-1-23 02:53:31 | 显示全部楼层 |阅读模式
1.首先建立一个java web工程,修改web.xml
<context-param> <description>The URL of the Message Broker to connect to</description>  <param-name>org.apache.activemq.brokerURL</param-name>  <param-value>tcp://localhost:61616</param-value> </context-param> <servlet-mapping>  <servlet-name>AjaxServlet</servlet-name>  <url-pattern>/amq/*</url-pattern> </servlet-mapping>  
2.建立一个测试JSP页面,我的页面主要代码如下
<script type="text/javascript" src="amq/amq.js"></script><script type="text/javascript">amq.uri='/MQ/amq';</script><script>var des = "topic://mqtest"; //设置一个topicvar myHandler ={  rcvMessage: function(message)  {var type=message.getAttribute('type');       var from=message.getAttribute('from');//alert(from);    document.getElementById("distext").value += type+":"+from;    document.getElementById("distext").value += "\r\n";  }};amq.addListener("anyID",des,myHandler.rcvMessage); //添加监听var go = function(){var myMessage = document.getElementById("cctext").value;var uid = document.getElementById("uid").value;amq.sendMessage(des,"<message type='"+ uid +"' from='" + myMessage + "'/>"); //发送消息};</script></head><body><textarea rows="10" cols="50" id="distext"></textarea><br>昵称:<input type="TEXT" id="uid"/><br>信息:<input type="TEXT" id="cctext"/><br><input type="button" value="开始" />3.启动AcitiveMQ
4.访问您应用的JSP页面来发送消息,功能类似一个聊天室。
您需要登录后才可以回帖 登录 | 立即注册 新浪微博账号登陆

本版积分规则

快速回复 返回顶部 返回列表