ActiveMQ使用AjaxServlet来实现ajax推
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页面来发送消息，功能类似一个聊天室。
页:
[1]