爲hazelcast配置atomikos

如何配置Atomikos爲HazelCast實例。根據mastering-hazel轉換，我們只能在java.lang中如何配置，就像我爲數據庫做的那樣。如果配置是java的方式，那麼我怎麼可以利用TransactionalTask的去除樣板代碼開始並承諾transactions.i試圖像爲hazelcast配置atomikos

public void insertIntoGridJTA(final List<String> list) 
      throws NotSupportedException, SystemException, 
      IllegalStateException, RollbackException { 
     HazelcastInstance hazelcast = Hazelcast.newHazelcastInstance(); 
     HazelcastXAResource xaResource = hazelcast.getXAResource(); 
     TransactionContext context = xaResource.getTransactionContext(); 
     hazelcast.executeTransaction(new TransactionalTask<Object>() { 
     public Object execute(TransactionalTaskContext context) 
        throws TransactionException { 
       // TODO Auto-generated method stub 
      TransactionalMap<Integer, String> map = context.getMap("demo"); 
      System.out.println("map"+map.getName()); 
      for (int i = 0; i < list.size(); i++) { 
       map.put(i, list.get(i)); 
      } 
       return null; 
     } 
     }); 
    }

但如果我使用TransactionalTask

來源

2016-03-08 pppavan

在你一看交易是不是開始我們示例中的Atomikos示例回購？ https://github.com/hazelcast/hazelcast-code-samples/blob/master/transactions/xa-transactions/src/main/java/XATransaction.java

來源

2016-03-15 11:12:37 noctarius

除了@noctarius，我已經在過去

@Autowired 
private JdbcTemplate jdbcTemplate; 
@Autowired 
private HazelcastXAResource hzXAResource; 
@Autowired 
private UserTransactionManager userTransactionManager; 

@Transactional 
public void insert() throws SystemException, RollbackException { 
    final Transaction transaction = userTransactionManager.getTransaction(); 
    transaction.enlistResource(hzXAResource); 
    final TransactionContext hzTransactionContext = hzXAResource.getTransactionContext(); 
    final TransactionalMap<Long, String> hzCustomerMap = hzTransactionContext.getMap("hzCustomerMap"); 

    // Use a Java 8 stream to print out each tuple of the list 
    CUSTOMERS_TEST_DATA.forEach(customer -> { 
     log.info("Inserting customer record for {}", customer); 
     hzCustomerMap.put(customer.getId(), customer.toString()); 
    }); 
    jdbcTemplate.batchUpdate(Sql.SQL_INSERT.getSql(), new BatchPreparedStatementSetter() { 
     @Override 
     public void setValues(PreparedStatement ps, int i) throws SQLException { 
      ps.setString(1, CUSTOMERS_TEST_DATA.get(i).getFirstName()); 
      ps.setString(2, CUSTOMERS_TEST_DATA.get(i).getLastName()); 
     } 

     @Override 
     public int getBatchSize() { 
      return CUSTOMERS_TEST_DATA.size(); 
     } 
    }); 

    // Uncomment this to test the failure of the transaction 
    //  hzCustomerMap.values((Predicate) entry -> { 
    //   throw new RuntimeException(); 
    //  }); 

    transaction.delistResource(hzXAResource, XAResource.TMSUCCESS); 
}

做了這樣的

來源

2017-11-16 23:10:10 phoenix

爲hazelcast配置atomikos

回答

相關問題