090-事务消息代码举例

好，那下面我们就来看一下这个代码啊。看代码直接看这。嗯。我们来看啊，首先。呃，这这都没啥可说的啊。呃，这个这这个。我们。把它换一下是吧。我们现在要的是这个啊。这个先不看啊，我们看它这是干嘛的。啊，这是。生产者指令。嗯，请列一个。线程，我在定一个线程，所以这个呢，它就是定义了一个线程。

嗯。这类的线程池，这个线程池，呃，我我不知道咱们大家啊，咱们咱们哥们对这个了解不了解啊，呃，我就当你不了解，我给你把这个这几个参数意义给大家写一下，这样不了解的兄弟们你也不用匆忙再查了。了解他的价啊，你就再再看一下就行了啊。呃。这个啊。他这个。没，没出来。我把这几个。考过了啊。

呃，首先啊，这个是。第一个。线程池是吧，有一个线车池，然后我们先看啊，这边第一个参数是它。是什么意思？啊，我们的就就这个。嗯，我看怎怎么怎么给大家写比较好一些啊。这第一个参数啊，呃，它它是我们指定我们核心线程的数量。其实。The number of，它保保持在什么啊，我们的。这个这个线程啊，所保存的这个线在池里边保存的这个线程数量，其实我们称称什么不是Co size。是吧，所以这个是。啊，核心。呃，县城。

线程数是吧，就是你现在池里边啊，你一直在维护的有这么多线程是吧。第二个就是他五，这五是什么呀，最多你最多几个。就是，呃。呃。呃，最多。牵着出是吧。这加上线程是轴核心线程数。呃，核心县城啊，数量是吧。然后。这儿100，这个100啊，它是。是什么呢？呃，这是个时间。这100是个时间啊。这后边是这个时间的单位。这是个单位。

这是时间。这是时间。这个时间是什么呢？啊，这是。一个啊时间是吧，就是当我们的这个。线程池里边线程数啊，大于这个核心线程数的时候。呃，你空闲的多余的空闲的线程。爱你。在这儿可以停留多长时间？是吧？呃，就我一这样一直空闲嘛，啊，我我可以停多长时间是吧，当。县城池中，呃。线程，线程。数量。大于核心线程。数量是。换卡吧。嗯，多。

啊，多余。空闲。县城。嗯。这个的乘。和。市场。是吧？呃，存活的时间，这是他的单位。下一个啊，你注意下一个是它就这个东西。是这个。这这这个参数啊。他叫什么？叫work q？我。它是什么呢？呃，这是这是个，这是个队列。这是个队列啊，这是个队列，呃。它里边这个参数。呃，是这个队列的长度。呃，我们大家知道啊，你我这里边现在指定了啊，最多就五个线程对吧，可如果说。啊，你这个你这个任务提交方法，一直不停的给我这个这个发送新的任务，我每一个任务。

呃，是要用一个线程去执行的。你一直给我发，我这同时最多就能执行你五个任务，那多出来的任务怎么办？我就给你存到这个队列里，所以这是个什么啊，临时存放队列。嗯。零零。临时。存放。呃，任务的。对是吧。临时存放任务队列是吧，你这个这个2000就是这个队列长度啊呃，其。呃，就是。对。啊，是这个对立上2000是吧？嗯。嗯。再往下。

这个县城工厂，那你这县城啊，一会创建了，一会销毁了，一会又创建了，一会刷毁了，你创建怎么创建的啊，这谁创建的县城。工厂是吧，那它里边这样这几个啊，这几个。参数啊，就是创建出来一个电能池，当然这些我相信我们很多哥们都清楚啊，呃，清楚你就。过了就行了，我们现在看它，看下一步，那这个是我们要说的东西，这是什么。Away。生产者是吧？为producer添加我们的。这什么竖变听器？Thank you。天天起。这15天练习，但这15天练习啊，我在这定义好了。就这个。就差。呃，我们这个一会儿分析它啊，我们现在先给它添加个事物间程器。

紧接着啊，让我开始了是吧，再往下。这大家看啊，我这有个text。个tag a t b t c是吧，三个啊，紧接着啊，这我这生产几个消息，三条消息我就生产三条啊message。这需要注意啊，我我这三条消息的tag分别是。TAG0 tag1 tag2，那正好是不是就是tag a tag b tag c？所以我这三条消息是不是三个T。对吧，紧接着我发送，注意你看这个发送发送什么失误消息。就发送事故消息啊在这。啊。十。这个发动事物消息大家看到啊，那后边还有一个闹，这个闹啊，我们现在其实不用管它是干嘛的呢，呃。

第二个参数啊，第二个参数啊，用于指定在。呃，执行本地事务。执行本地事务时要使用的啊业务。参数你要如果要用业务参数的话。哎，那你就可以在这儿给他指定，我这不需要。因为大家注意啊，他在这儿实际上就开启了它这个发送，一发送相当于这里边儿就走了谁了啊。开启拳击手。就开启全局事物，开启全局事物这里边是不是会有本地事物，就你要执行这些本地事物的时候需要用到的参数。需要用到参数啊，大家可以看一眼，你看。不就是这个二嘛，是吧，那那不就是它吗。是吧？啊，然后我们看这个。

就这个阿，你看阿用在哪了啊。在这儿呢？是吧，这是什么执行？呃，执行本地事务是吧，执行本地事务branch分支吗？是不是就在执行本地事务的时候啊，你要用到这些啊，业务参数，用到的业务参数啊。他这还没有没有给。我们看看这儿，诶这也没有。这也没有，没有这个的，你看啊，再看看这。这个。是什么啊，自定义的是不是业务参数是吧，就我们我们需要用到的啊，你就你就给他传，我们现在不用不用你不用管它啊。紧接着我这输出一个结果是吧，输出一个结果那就是。那现在啊，我这儿需要分析的是这这个东西是吧？啊，这是我们的爱存不存是吧，爱存不存啊这个这个这个是吧，呃，工行的，呃，他的事务啊。

受受点电器啊。大家看这个是什么东西，这个方法。这什么？这就是我们的。我们需要啊，需要实现transaction listener啊，这个就是我们的。回调合作。他就是我们的回调操作。消息预提交成功啊，就会触发我们这个。这个方案来执行。你看。他。你这边是不是一提交成功了，就会触发他的执行啊。对不对。哎，之前我们本地事物。

对吧，所以。嗯。消息。提交。成功。就会。出发。该方法的。这些。啊用。用于完成本地。本地事对吧，那本地事物你做什么呀。哎，你看一提交消息成功了啊，给给了个提示，紧接着呃，我这样啊，为了呃我能演示出这种效果啊，我是这样。就是你我知道如果啊，消息里边tag消息的tag啊，如果是tag a。啊，我就是成功。就表示扣款成功了啊。所以我返回的就是它，如果是TB，呃，那就是扣款失败。如果是TC，就我我也不知道成功还是失败是多。知道吧，所以这里边啊。

呃，给大家写上吧，呃，假设。假设啊，接收到的接收到，呃。诶。TA的消息。嗯。接到T的消息就表示。呃。这个扣款。操作成功。成功是吧，然后。Tag。嗯。的消息表示，呃。Coke。是吧？Tag。表示。呃，扣扣扣扣扣扣，扣款结果不清楚。

不清楚就怎么。需要。执行。回查。消息。对不对，需要执行消息。为啥？消会差在哪？这个就是消会差。这就是消息。就是回回到操作。对吧，消息回查，消息回查，那那我们这这呃执行消息回查，你看到就行了，然后这这肯定是谁，我们这个肯定是TC啊，定是TC观查的结果是。成功了。Commit是吧，不要结果，Commit。呃。

那么。当然这个回查啊，刚才我们说这个回查方法，呃，调这个消息回查啊，除了这反复弄以外，还有是吧，我们在这。回肠。我拷贝一下他行啊。要加到这。就谁触发了这个方。是吧？要不这俩可以触发回城，OK？好，那现在我们运行一下啊，我们运行一下它。呃，注意啊，我这里边儿这个消息。生产消息。是some topic啊，你注意诶。

Some topic。Some。Some。或者这样吧。我。Topic。呃。呃，我我这个T。我我叫t trans，我叫t topic啊，我叫T，咱们换一个是吧。走起。看到啊，再过一会儿再看啊，过一会儿过一会儿再看。看战力。看到没有？你看我我这这是预提交，然后发送成功成功成功，这执行了一个回场，为什么会执行回场。为什么？

是不是你这个C过来了。对不对，C过来了，我就要执行回查，那为什么又等了一会儿。为什么等了一会儿，他他这里边不是有我们刚才说那里那几个属性里边嘛，是吧，啊，你按诺了，然后我要稍稍等一会儿是吧，这里边有个延迟，哎，然后我就我在。他要从试啊，他要重试是吧，哎，你看这执行的这个。会查了对吧，然后我们再让他消费一下，你看这个消费过程，我们消费者呢，不用再重新定义了啊，我们我们直接拷贝。这里面就有消费者拷贝摊就行，咱们把它拷过来，我我放到这儿啊。给它放在这儿。换到这以后，但是这个得改一下。我是TC。其他都不用动啊。其他都不用动，就光改一下，他就你你消费谁是吧，好。

现在。从头的啊，我一共三条消息。你看他只能消费谁。他现在。消费了你注意啊，你注意注意注意注意看注意看。T。嗯，我们看一下谁呢。Tag。你看这个tag。这个是TA。这个是taxi。是不是？我消费的tag a和tag c这两条。没错吧？哎，为什么他消费的是tag a和tag c，为什么没有消费tag b呢？

思考一下这个问题。为什么消费的是tag？A和TC。是因为啊你T。TA啊，你是。什么意思，我们这儿。在哪儿给他架着注射？哎，在这。你tag a表示扣款成功了，TB是不是扣款失败，失败它就整体会回滚呢？你这样如你这样啊，如果扣款失败了，是不是整体就回滚了。那所以他这个也就回国，你这个消息就没有提交到我们的brokeer，就是那个TB的那个消息，这里面就没有。那为什么TC的也可以TC的最终是不是提交的仍然是？最终我成功了呀。

所以我们可以看到这里边儿。消息。会出现几条消息，我们T。他应该出现两条消息。而不是三条。对吧，T的C和TA。两条消息，而不是在没有。对不对，所以我写到这里边就写了俩。OK了吧？是不是这样大家也就也就理解了啊，这样大家也就理解了。嗯，OKOK，那就这样。嗯。我来把这个也给大家。不是的。就是减震器。嗯，还有谁，还有我们的监听器。

先联系。呃，我再给你写上一句啊这个。叫消费者是吧。嗯。消费者，呃。我们写上一句吧。二六。直接使用。呃，使用谁，我们前面这个普通消息是吧，呃，普通消息的。Some。好，出门。做。对。消费者。

Television。是吧，那我给你。嗯。我我给大家放这儿吧。那这就考虑过来这个东西。好。那么关于。这个。事消息啊，我们给大家可以说已经。很深入的进行了一个调解。OK。