如何利用ActiveMq如何定时刷新网页页

来源：蜘蛛抓取(WebSpider) 时间：2014-12-04 03:26 标签： 如何自动刷新网页
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
您的访问请求被拒绝 403 Forbidden - ITeye技术社区
您的访问请求被拒绝
亲爱的会员，您的IP地址所在网段被ITeye拒绝服务，这可能是以下两种情况导致：
一、您所在的网段内有网络爬虫大量抓取ITeye网页，为保证其他人流畅的访问ITeye，该网段被ITeye拒绝
二、您通过某个代理服务器访问ITeye网站，该代理服务器被网络爬虫利用，大量抓取ITeye网页
请您点击按钮解除封锁&<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
您的访问请求被拒绝 403 Forbidden - ITeye技术社区
您的访问请求被拒绝
亲爱的会员，您的IP地址所在网段被ITeye拒绝服务，这可能是以下两种情况导致：
一、您所在的网段内有网络爬虫大量抓取ITeye网页，为保证其他人流畅的访问ITeye，该网段被ITeye拒绝
二、您通过某个代理服务器访问ITeye网站，该代理服务器被网络爬虫利用，大量抓取ITeye网页
请您点击按钮解除封锁&ActiveMQ开发手册_百度文库
两大类热门资源免费畅读
续费一年阅读会员，立省24元！
ActiveMQ开发手册
上传于||文档简介
&&整&#8203;理&#8203;了&#8203;一&#8203;下&#8203;,&#8203;赞&#8203;一&#8203;个&#8203;!
阅读已结束，如果下载本文需要使用1下载券
想免费下载本文？
下载文档到电脑，查找使用更方便
还剩19页未读，继续阅读
你可能喜欢Write everything down.
本博客为学习、笔记之用，以笔记记录作者学习的知识与学习后的思考或感悟。学习过程可能参考各种资料，如觉文中表述过分引用，请务必告知，以便迅速处理。如有错漏，不吝赐教。
到ActiveMQ官网，找到下载点。
官网为http://activemq.apache.org/
Linux版本下载点之一为：/activemq/5.11.1/apache-activemq-5.11.1-bin.tar.gz
下载到本机，并解压
wget http:///activemq/5.11.1/apache-activemq-5.11.1-bin.tar.gz
tar -xf ./apache-activemq-5.11.1-bin.tar.gz
启动（当然，由于依赖于JAVA，如果你没有安装JAVA，它会提醒你的，哈哈）
cd ./apache-activemq-5.11.1-bin/bin
./activemq start
&测试启动成功与否
ActiveMQ默认监听61616端口，查此端口看看是否成功启动
netstat -an|grep 61616
如果一切顺利，会看到如下日志
[nicchagil@localhost bin]$ ./activemq start
INFO: Loading '/home/nicchagil/app/apache-activemq-5.11.1/bin/env'
INFO: Using java '/home/nicchagil/app/jdk1.7.0_71//bin/java'
INFO: Starting - inspect logfiles specified in logging.properties and log4j.prop
erties to get details
INFO: pidfile created : '/home/nicchagil/app/apache-activemq-5.11.1/data/activem
q.pid' (pid '4858')
[nicchagil@localhost bin]$
[nicchagil@localhost bin]$
[nicchagil@localhost bin]$
[nicchagil@localhost bin]$ netstat -an | grep 61616
0 :::61616
[nicchagil@localhost bin]$
顺便，登录下管理员页面，看看有木有问题：
URL : http://10.0.0.109:8161/admin/
ACC/PWD : admin/admin
&尝试基本消息功能
接下来，用简单的点对点测试消息发送、消息接收。
activemq-client-5.11.1.jar
geronimo-j2ee-management_1.1_spec-1.0.1.jar
geronimo-jms_1.1_spec-1.1.1.jar
hawtbuf-1.11.jar
slf4j-api-1.7.10.jar
package com.nicchagil.activemq.study.No001点对点;
import javax.jms.C
import javax.jms.ConnectionF
import javax.jms.DeliveryM
import javax.jms.D
import javax.jms.JMSE
import javax.jms.MessageP
import javax.jms.ObjectM
import javax.jms.S
import org.apache.activemq.ActiveMQC
import org.apache.activemq.ActiveMQConnectionF
public class Sender {
public static void main(String[] args) throws JMSException {
ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://10.0.0.109:61616");
Connection connection = factory.createConnection();
connection.start();
Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("TestQueue");
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
ObjectMessage message = session.createObjectMessage("hello world...");
producer.send(message);
System.out.println("sent...");
package com.nicchagil.activemq.study.No001点对点;
import javax.jms.C
import javax.jms.ConnectionF
import javax.jms.D
import javax.jms.JMSE
import javax.jms.MessageC
import javax.jms.ObjectM
import javax.jms.S
import org.apache.activemq.ActiveMQC
import org.apache.activemq.ActiveMQConnectionF
public class Receiver {
public static void main(String[] args) throws JMSException {
ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://10.0.0.109:61616");
Connection connection = factory.createConnection();
connection.start();
Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("TestQueue");
MessageConsumer consumer = session.createConsumer(destination);
ObjectMessage message = (ObjectMessage)consumer.receive();
if (message != null) {
String messageString = (String)message.getObject();
System.out.println("Receive : " + messageString);
看到console打印出：Receive : hello world...，可知接收到消息了，内流满面啊啊啊啊。。。
查询进程id（pid），禁止其进程：
ps -ef | grep activemq
kill -9 pid
再运行Sender，她就无法连接了，哈哈哈哈哈
Exception in thread "main" javax.jms.JMSException: Could not connect to broker URL: tcp://10.0.0.109:61616. Reason: java.net.ConnectException: Connection refused: connect
好了，基本的搭建告一段落。
过程中，遇到一个小问题，就是我一开始是用JDK1.6去跑的，报出常见的Unsupported major.minor version 51.0
针对这个问题，这个帖子有很好的参考意义：
/chinafine/articles/1935748.html
找出jar中的一个class，执行以下命令，可查出minor version、major version：
javap -verbose yourClassName
或直接查看jar中的META-INF\MANIFEST.MF。
然后对照帖子中的JDK版本，换成JDK1.7就OK了。
阅读(...) 评论()<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
您的访问请求被拒绝 403 Forbidden - ITeye技术社区
您的访问请求被拒绝
亲爱的会员，您的IP地址所在网段被ITeye拒绝服务，这可能是以下两种情况导致：
一、您所在的网段内有网络爬虫大量抓取ITeye网页，为保证其他人流畅的访问ITeye，该网段被ITeye拒绝
二、您通过某个代理服务器访问ITeye网站，该代理服务器被网络爬虫利用，大量抓取ITeye网页
请您点击按钮解除封锁&

我要回帖

更多关于 如何自动刷新网页 的文章

 

随机推荐