亚洲综合激情无码乱自慰,2023国产精品自在拍在线播放,精品午夜国产人人幅利

作者：小傅哥，博客：https://bugstack.cn

大家好，我是技術(shù)UP主小傅哥。

說到底，無論是晉升述職還是面試考察，編程技能的展現(xiàn)總是在那些技術(shù)的橫向?qū)Ρ群蜕疃鹊牧私膺\(yùn)用。知其一，也知其二。一個場景的問題，往往也會對應(yīng)著多種的解決方案，從沒有絕對的好和不好，都是是否適合而已。所以，往往技術(shù)越好的，也越低調(diào)，不那么咋咋呼呼的。

什么是柔性事務(wù)？

在分布式軟件系統(tǒng)架構(gòu)設(shè)計(jì)中，所有的并發(fā)資源的競爭，都會往無鎖化、非獨(dú)占競爭，以及柔性事務(wù)設(shè)計(jì)。柔性事務(wù)用于替代傳統(tǒng)事務(wù)管理中（如ACID屬性：原子性、一致性、隔離性、持久性），在分布式架構(gòu)系統(tǒng)中的使用場景。通過消息、補(bǔ)償，協(xié)調(diào)不同服務(wù)間的一致性。

那么在消息的使用中，除了有 MQ 消息，使用于微服務(wù)之間。還有本地消息，可以作用在各個領(lǐng)域間驅(qū)動流程。關(guān)于本地消息可以用，Spring 的監(jiān)聽、Redis 發(fā)布訂閱、Guava EventBus 事件總線，這些內(nèi)容在小傅哥博客 bugstack.cn 《路書》中有相關(guān)的案例。之后本節(jié)咱們介紹一個新的高性能組件 Disruptor 的使用。

一、關(guān)于 Disruptor

Disruptor 是一種高性能的并發(fā)框架，最初由 LMAX 開發(fā)，用于解決高吞吐量、低延遲的消息處理問題。它提供了一種無鎖的、有序的事件處理模型，非常適合處理需要高性能的場景。Disruptor 本身并不是用于實(shí)現(xiàn)事務(wù)的框架，而是一個事件處理器。因此，要在 Disruptor 上實(shí)現(xiàn)柔性事務(wù)，需要結(jié)合其事件處理能力與柔性事務(wù)的模式。

源碼：https://github.com/LMAX-Exchange/disruptor文檔：https://lmax-exchange.github.io/disruptor/ - 谷歌瀏覽器右鍵點(diǎn)翻譯為中文。

二、實(shí)戰(zhàn)案例

1. 工程結(jié)構(gòu)

小傅哥準(zhǔn)備好了一份基于 Disruptor 事件消息的使用案例工程，你可以直接上手體現(xiàn)。

觸發(fā)器

2. 引入POM

<!-- https://mvnrepository.com/artifact/com.lmax/disruptor -->
<dependency>
    <groupId>com.lmax</groupId>
    <artifactId>disruptor</artifactId>
    <version>3.4.4</version>
</dependency>

引入 disruptor pom 包。

3. 監(jiān)聽消息

@Slf4j
public?class?XxxEventHandler?implements?EventHandler<XxxEventHandler.Message>?{

????@Override
????public?void?onEvent(Message?longEvent,?long?l,?boolean?b)?throws?Exception?{
????????log.info("接收消息：{}",?longEvent.getValue());
????}

????@Data
????public?static?class?Message?{
????????private?String?value;
????}

}

在 trigger 下 event 包內(nèi)，加一個實(shí)現(xiàn)了 disruptor EventHandler 的監(jiān)聽實(shí)現(xiàn)類，消息體類型我們定義到 XxxEventHandler 中，也就是 Message。具體生產(chǎn)使用的時候，按需調(diào)整。這個接收消息的過程和使用 MQ 的方式是一樣的。

4. 實(shí)例化監(jiān)聽

@Configuration
public?class?DisruptorConfig?{

????private?final?ExecutorService?executor?=?Executors.newCachedThreadPool();

????@Bean("xxxEventDisruptor")
????public?Disruptor<XxxEventHandler.Message>?disruptor()?{
????????//?環(huán)形隊(duì)列的大小，注意要是2的冪
????????int?bufferSize?=?1024;

????????//?創(chuàng)建Disruptor
????????Disruptor<XxxEventHandler.Message>?disruptor?=?new?Disruptor<>(XxxEventHandler.Message::new,?bufferSize,?executor);

????????//?連接事件處理器
????????disruptor.handleEventsWith(new?XxxEventHandler());

????????//?開始Disruptor
????????disruptor.start();

????????return?disruptor;
????}

}

在 App 模塊下，有一個 config 專門的配置類，在這里配置下消息監(jiān)聽。這個過程和我們之前使用的 Redis 發(fā)布訂閱是一樣的。

5. 推送消息(Test)

@Slf4j
@RunWith(SpringRunner.class)
@SpringBootTest(classes?=?Application.class)
public?class?DisruptorTest?{

????@Resource
????private?Disruptor<XxxEventHandler.Message>?xxxEventDisruptor;

????@Test
????public?void?test_publishEvent()?throws?InterruptedException?{

????????for?(int?i?=?0;?i?<?10;?i++)?{
????????????xxxEventDisruptor.publishEvent((event,?sequence)?->?event.setValue("你好，我是?Disruptor?Message"));
????????}

????????//?暫停?-?測試完手動關(guān)閉程序
????????new?CountDownLatch(1).await();
????}

}

24-10-26.11:55:55.827?[main????????????]?INFO??DisruptorTest??????????-?Starting?DisruptorTest?using?Java?1.8.0_311?on?MacBook-Pro.local?with?PID?92827?(started?by?fuzhengwei?in?/Users/fuzhengwei/1024/KnowledgePlanet/road-map/xfg-dev-tech-disruptor/xfg-dev-tech-app)
24-10-26.11:55:55.829?[main????????????]?INFO??DisruptorTest??????????-?The?following?1?profile?is?active:?"dev"
24-10-26.11:55:57.749?[main????????????]?INFO??DisruptorTest??????????-?Started?DisruptorTest?in?2.526?seconds?(JVM?running?for?3.741)
24-10-26.11:55:58.125?[pool-2-thread-1?] INFO  XxxEventHandler ???????-?接收消息：你好，我是 Disruptor Message
24-10-26.11:55:58.128?[pool-2-thread-1?] INFO  XxxEventHandler ???????-?接收消息：你好，我是 Disruptor Message
24-10-26.11:55:58.128?[pool-2-thread-1?] INFO  XxxEventHandler ???????-?接收消息：你好，我是 Disruptor Message
24-10-26.11:55:58.128?[pool-2-thread-1?] INFO  XxxEventHandler ???????-?接收消息：你好，我是 Disruptor Message
24-10-26.11:55:58.128?[pool-2-thread-1?] INFO  XxxEventHandler ???????-?接收消息：你好，我是 Disruptor Message
24-10-26.11:55:58.128?[pool-2-thread-1?] INFO  XxxEventHandler ???????-?接收消息：你好，我是 Disruptor Message
24-10-26.11:55:58.128?[pool-2-thread-1?] INFO  XxxEventHandler ???????-?接收消息：你好，我是 Disruptor Message
24-10-26.11:55:58.128?[pool-2-thread-1?] INFO  XxxEventHandler ???????-?接收消息：你好，我是 Disruptor Message
24-10-26.11:55:58.128?[pool-2-thread-1?] INFO  XxxEventHandler ???????-?接收消息：你好，我是 Disruptor Message
24-10-26.11:55:58.128?[pool-2-thread-1?] INFO  XxxEventHandler ???????-?接收消息：你好，我是 Disruptor Message

提供一個單測來測試消息推送，這樣你就可以監(jiān)聽到消息了。

三、總結(jié)

在美團(tuán)、京東、阿里，等各個大廠中都有很多這樣的組件使用，在美團(tuán)發(fā)布過的文章中《高性能隊(duì)列——Disruptor》還有一個對應(yīng)的壓測數(shù)據(jù)。CPU:Intel Core i7-2720QM，JVM:Java 1.6.0_25 64-bit，OS:Ubuntu 11.04

-	ABQ	Disruptor
Unicast: 1P – 1C	4,057,453	22,381,378
Pipeline: 1P – 3C	2,006,903	15,857,913
Sequencer: 3P – 1C	2,056,118	14,540,519
Multicast: 1P – 3C	260,733	10,860,121
Diamond: 1P – 3C	2,082,725	15,295,197

依據(jù)并發(fā)競爭的激烈程度的不同，Disruptor比ArrayBlockingQueue吞吐量快4~7倍。

另外，Log4j 2 采用了 Disruptor（一種無鎖的線程間通信庫），提高吞吐量降低延遲。在生產(chǎn)使用中，大并發(fā)的系統(tǒng)注意 Log4j 版本。官網(wǎng)說明：https://logging.apache.org/log4j/2.12.x/manual/async.html

應(yīng)用程序

四、技術(shù)實(shí)戰(zhàn)

加入小傅哥的星球「碼農(nóng)會鎖」閱讀450+份簡歷和評審，學(xué)習(xí)6個業(yè)務(wù)項(xiàng)目；MVC+DDD，雙架構(gòu)開發(fā)小型電商、大營銷（超級大課）、OpenAI 大模型應(yīng)用、Lottery、IM、AI 問答助手。7個組件項(xiàng)目；OpenAI 代碼評審、BCP 透視業(yè)務(wù)監(jiān)控、動態(tài)線程池、支付SDK設(shè)計(jì)和開發(fā)、API網(wǎng)關(guān)、SpringBoot Starter、IDEA Plugin 插件開發(fā)。1套源碼課程、1套基礎(chǔ)教程、1到云服務(wù)器教程以及各類場景解決方案。