@ entity公共类PurchaseOrder｛@ id@GeneratedValue(发电机=＂序列＂）generator(name =＂序列＂， sequenceName =＂seq_po＂， initialValue =1001， allocationSize =50）私人长id;私人字符串客户;@ManyToOne私人项项目;私人int量;私人BigDecimaltotalPrice;/ /……｝

@ entity@Cacheable公共类项｛@ id私人长id;私人字符串描述;私人BigDecimal价格;/ /……｝

<？XML版本="1.0"编码="utf-8"?><持久性xmlns＝＂http://xmlns.jcp.org/xml/ns/persistence＂xmlns: xsi＝＂http://www.w3.org/2001/XMLSchema-instance＂xsi: schemaLocation＝＂.．.＂版本＝＂2．2＂><持久化单元的名字＝＂orders-PU-JTA＂交易类型＝＂JTA＂>< jta-data-source >java: jboss /数据源/ OrderDS< / jta-data-source >< shared-cache-mode >ENABLE_SELECTIVE< / shared-cache-mode >< >属性<属性的名字＝＂hibernate.cache.use_second_level_cache＂价值＝＂真正的＂/><属性的名字＝＂hibernate.show_sql＂价值＝＂真正的＂/><属性的名字＝＂hibernate.format_sql＂价值＝＂真正的＂/><属性的名字＝＂hibernate.generate_statistics＂价值＝＂真正的＂/><！——方言等. ...-->< / >属性< /持久化单元>< /持久性>

> curl -H "Content-Type: application/json" \ -X POST \——data '{"customer": "Billy-Bob"， "itemId": 10003， "quantity": 2}' \ http://localhost:8080/cache-invalidation/rest/orders

{"id": 1002， "customer": "Billy-Bob"， "item": {"id":10003， "description": "North By Northwest"， "price": 14.99}， "quantity": 2， "totalPrice": 29.98}

$POSTGRES_USER $POSTGRES_DB -c "UPDATE item SET price = 20.99 where id = 10003"

@ApplicationScoped公共类开云体育电动老虎机DatabaseChangeEventListener｛@私人ManagedExecutorService executorService;@PersistenceUnit私人被电动势;@PersistenceContext私人EntityManager em;私人EmbeddedEngine引擎;公共无效startEmbeddedEngine (@Observes@Initialized(ApplicationScoped.class)对象init) {配置配置=配置.empty() . withsystemproperties (Function.identity()).edit() .with(EmbeddedEngine.;)CONNECTOR_CLASS, PostgresConnector.class) .with(EmbeddedEngine.ENGINE_NAME，＂cache-invalidation-engine＂) (EmbeddedEngine。OFFSET_STORAGE, MemoryOffsetBackingStore.class .with(＂的名字＂，＂cache-invalidation-connector＂) (＂开云体育电动老虎机database.hostname＂，＂postgres＂) (＂开云体育电动老虎机database.port＂，5432) (＂开云体育电动老虎机database.user＂，＂postgresuser＂) (＂开云体育电动老虎机database.password＂，＂postgrespw＂) (＂开云体育电动老虎机database.server.name＂，＂dbserver1＂) (＂开云体育电动老虎机database.dbname＂，＂库存＂) (＂开云体育电动老虎机database.whitelist＂，＂公共＂) (＂snapshot.mode＂，＂从来没有＂) .build ();这.engine = EmbeddedEngine.create() .using(config) .notifying(这:: handleDbChangeEvent) .build ();executorService.execute(引擎);｝@PreDestroy公共无效shutdownEngine() {engine.stop();｝私人无效handleDbChangeEvent(源记录){如果(record.topic () .equals (＂dbserver1.public.item＂)) {长itemId = (结构体) record.key ()) .getInt64 (＂id＂）;结构体有效载荷= (结构体) record.value ();操作op =操作.forCode (payload.getString (＂人事处＂));如果(op = =操作.UPDATE || op ==操作.DELETE) {emf.getCache().evict(Item.class, itemId);} } } }

@ApplicationScoped公共类KnownTransactions｛私人最后DefaultCacheManager缓存管理器;私人最后缓存<长，布尔> applicationTransactions;公共KnownTransactions() {cacheManager =新DefaultCacheManager ();cacheManager.defineConfiguration (＂tx-id-cache＂，新ConfigurationBuilder() .expiration() .lifespan(60，TimeUnit.SECONDS) .build());applicationTransactions = cacheManager.getCache(＂tx-id-cache＂）;｝@PreDestroy公共无效stopCacheManager() {cacheManager.stop();｝公共无效注册(长{applicationTransactions.put(txId，真正的）;｝公共布尔称为(长txId) {返回布尔.TRUE.equals (applicationTransactions.get (txId));}}

类TransactionRegistrationListener实现了FlushEventListener {私人挥发性KnownTransactions KnownTransactions;公共TransactionRegistrationListener() {}@Override公共无效onFlush (FlushEvent事件)抛出HibernateException {event.getSession(). getactionqueue()。registerProcess(session -> {数量txId = (数量) event.getSession () .createNativeQuery (＂选择txid_current ()＂) .setFlushMode(FlushMode.MANUAL) .getSingleResult();getKnownTransactions () .register (txId.longValue ());});｝私人KnownTransactions getKnownTransactions() {KnownTransactions值= KnownTransactions;如果(值= =零) {knownTransactions = value = CDI.current().select(knownTransactions .class).get();｝返回价值;}}

公共类TransactionRegistrationIntegrator实现了积分器{@Override公共无效集成(元数据元数据，SessionFactoryImplementor sessionFactory, SessionFactoryServiceRegistry serviceRegistry) {serviceRegistry. getservice (EventListenerRegistry.class) .appendListeners(EventType.FLUSH，新TransactionRegistrationListener ());｝@Override公共无效disintegrate(SessionFactoryImplementor sessionFactory, SessionFactoryServiceRegistry serviceRegistry) {}}

io.开云体育官方注册网址debezium.examples.cacheinvalidation.persistence.TransactionRegistrationIntegrator

@ApplicationScoped公共类开云体育电动老虎机DatabaseChangeEventListener｛/ /……@ inject私人KnownTransactions KnownTransactions;私人无效handleDbChangeEvent(源记录){如果(record.topic () .equals (＂dbserver1.public.item＂)) {长itemId = (结构体) record.key ()) .getInt64 (＂id＂）;结构体有效载荷= (结构体) record.value ();操作op =操作.forCode (payload.getString (＂人事处＂));长txId = (结构体) payload.get (＂源＂) .getInt64 (＂txId＂）;如果(!knownTransactions.isKnown(txId) && (op ==操作.UPDATE || op ==操作.DELETE)) {emf.getCache().evict(Item.class, itemId);} } } }

> curl -H "Content-Type: application/json" \ -X PUT \——data '{"description": "西北偏北"，"price": 20.99}' \ http://localhost:8080/cache-invalidation/rest/items/10003