ActiveMQ HelloWorld实例

一、下载ActiveMQ
http://activemq.apache.org/download.html

二、启动ActiveMQ
运行bin目录下的activemq.bat即可,此例用到的是61616端口和8161端口

注意:
ActiveMQ对JDK版本有要求,最新版ActiveMQ 5.14.4与JDK1.6是不兼容的,此时ActiveMQ端口无法启动,本地代码亦无法运行,报错:Unsupported major.minor version 51.0。
因此要成功运行代码要么升级JDK版本,要么使用旧版本的ActiveMQ。
以下代码测试使用的是JDK1.6和ActiveMQ 5.0.0,这是第一个带有web控制台的版本(http://localhost:8161/admin/)。
Continue reading

Java生产者消费者模式

1
2
3
4
5
6
7
8
9
10
/*
 * 需求:实现生产者-消费者模式,可以有多个生产者和多个消费者
 * 程序关键点:
 * 1、解决重复生产、重复消费的问题,需要使用synchronized(通过资源对象)进行同步
 * 2、生产、消费方法放在资源类中定义
 * 3、解决未生产先消费、已消费未生产的问题,实现生产一个消费一个,需要线程间通信并使用标志进行判断
 * 4、notify可能产生死锁,notifyAll可以唤醒其他所有线程
 * 5、wait()和notifyAll()省略了this
 *
 * **/

Continue reading