|
|
@ -23,6 +23,7 @@ public class CountDTOMessageEventProducer {
|
|
|
|
//给这个区块放入 数据 如果此处不理解,想想RingBuffer的结构图
|
|
|
|
//给这个区块放入 数据 如果此处不理解,想想RingBuffer的结构图
|
|
|
|
ringBuffer.get(seq).setIndex(index);
|
|
|
|
ringBuffer.get(seq).setIndex(index);
|
|
|
|
ringBuffer.get(seq).setCpUserId(cpUserId);
|
|
|
|
ringBuffer.get(seq).setCpUserId(cpUserId);
|
|
|
|
|
|
|
|
ringBuffer.get(seq).setPrivilageCpUserDOMapper(privilageCpUserDOMapper);
|
|
|
|
} finally {
|
|
|
|
} finally {
|
|
|
|
// 发布Event,激活观察者去消费, 将sequence传递给该消费者
|
|
|
|
// 发布Event,激活观察者去消费, 将sequence传递给该消费者
|
|
|
|
// 注意,最后的 ringBuffer.publish() 方法必须包含在 finally 中以确保必须得到调用;如果某个请求的 sequence 未被提交,将会堵塞后续的发布操作或者其它的 producer。
|
|
|
|
// 注意,最后的 ringBuffer.publish() 方法必须包含在 finally 中以确保必须得到调用;如果某个请求的 sequence 未被提交,将会堵塞后续的发布操作或者其它的 producer。
|
|
|
|