上一篇已经讲了JMS的基本概念，这一篇来上手练一练，如果对JMS基本概念还不熟悉，欢迎参靠JMS基本概。

这篇文章所使用的代码已经不是我刚入手时的代码，已经经过我重构过的代码，便于理解，并且加了很多中文注释，希望对大家有所帮助。

在基本概念一篇中已经讲到，JMS有两种消息模型，一种是点对点，另一种的发布/订阅模式。本篇文章就基于这两种消息模型来写例子。

点对点模型

        先看一下生产者代码：

        我写了两种消息消费者，其实也就是上一篇讲的同步消费和异步消费。

        先来看异步消费者：

        异步消费者通过设置监听器来达到异步消费消息的目的。其实这个监听器也很简单，我们来看一下。

        这里只有一个方法。

        为了便于理解，我先把父类贴出来，这样就可以基本完整的看了。

        用到的常量类

        来个测试类吧，这样就完整了

        现在为止，一个异步消息的完整例子就真的完整了，我是为了便于看到消息的消费过程，所以把生产者放到了一个线程里来不断的生产消息，来通过观察消费者打印的消费信息，了解消费的过程。

        再来看看同步消息模式：

        同步消费的方式就是轮训的去要有没有消息，有没有消息。为了适应我的测试类，我把同步消息消费也按照异步消费的模式做了相应的改动，下边就是代码：

        在这里，我选择启动一个线程去设置一个监听器，为什么要启动线程，因为我上边提到了要适应我的测试类，我是先初始化消费者，如果不用线程，那么消费者就会在要消息的时候夯住，因为：

        这个方法是阻塞式方法。会程序在初始化消费者后就会夯住，然后生成者无法启动，无法生成消息，整个程序就死锁了，为了解决这个问题，所以采用模拟异步消费的方式来写同步消费例子。

        下边来看我写的丑陋的监听器：

        为什么称为丑陋的监听器，相信大家也不难发现，因为采用循环方式，并不是真正的监听器。 看了这两个监听器，那么我提出一个问题，这个问题也是在我写这篇文章的时候发现的，如果我再写一个抽象类去作为这两个监听器的父类，把onMessage方法提出来，是不是更加优化了，因为我发现两个onMessage方法其实一样，我也是故意给做的一样的。

        当然今天讲的并不是Java的重构，而是JMS，这个问题就作为题外话好了。

        现在你自己也可以去跑一跑这两个例子，细心的同学或发现在测试类中其实有一行有疑问。为什么发送结束消息的方法要加参数，可以设置发送多个结束消息。这个问题我们稍后介绍，下面我来运行一下代码，也许你就渐渐明白。

        先跑一个异步消费的例子：

        然后再来跑一个同步消费的例子：

        只需把注水换一换就行了。

        大家会发现和异步消费并未区别，因为其实也是异步消费。

        那么如果我现在把测试类的注释都打开，会是什么结果呢：

        这个时候有俩个消费者，一个消费者消费了一半的消息，这里我没有深入研究这种消费平均的方式是随机的还是真的平均，我猜猜可能是真的平均，因为我运行了多次都是同样的结果。

        通过我打出来的消息，发现只有一个消费者结束了，另一个并没有结束，因为没有收到结束消息标志，所以需要发送两个结束标志才能使两个消费者都能结束。

        这也正是我设置参数的原因：

        改成2之后再来运行一次：

        现在两个消费者都正常结束了。到此我的点对点模式就介绍完了。

订阅/发布模式

        生产者：

        消费者：

        大家可以看出相比点对点模式的例子，消息的订阅/发布模式只做了很小的改动：

        其他代码都重用了，接下来是测试类：

        运行这个例子：

        两个订阅者获取的消息一模一样，并不是平半分了消息，这就是订阅/发布与点对点的不同。

        注：订阅/发布模式必须要先订阅，这样订阅者才能收到消息。

完