springbatch apache

gdrocket

　　

　　简单测试如下：
　　1：收下下载apache-activemq-5.14.4 解压apache-activemq-5.14.4\bin\win64，运行activemq.bat
　　启动本地MQ服务器。
　　通过浏览器可以查看本地MQ服务器的信息。
　　http://127.0.0.1:8161/admin/index.jsp
　　2: 先往mq中put数据
　　配置如下：


        
            
               
            
        
      
     
        

        
            
               
            
        
    　　


　　






















public class CreditBillProcessor implements ItemProcessor {
private JdbcTemplate jdbcTemplate = null;
public JdbcTemplate getJdbcTemplate() {
return jdbcTemplate;
}
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
@Override
public BizArgs process(BizArgs bizArgs) throws Exception {
System.out.println(bizArgs);
return bizArgs;
}
}
public static void main(String[] args) {
//ApplicationContext context = getContext("springJob/mq/job-db-jdbc-month01-putMq.xml");
ApplicationContext context = getContext("springJob/mq/job-db-jdbc-month01-getMq.xml");
//JmsTemplate jmsTemplate = getJmsTemplate(context);
//sendMessage(jmsTemplate, new CreditBill("4047390012345678","tom",100.00,"2013-2-2 12:00:08","Lu Jia Zui road"));
//sendMessage(jmsTemplate, new CreditBill("4047390012345678","tom",320,"2013-2-3 10:35:21","Lu Jia Zui road"));
//sendMessage(jmsTemplate, new CreditBill("4047390012345678","tom",360.00,"2013-2-11 11:12:38","Longyang road"));
executeJob(context, "jmsReadJob",
new JobParametersBuilder().addDate("date", new Date()));
}　　完事后，apache-activemq服务器中会多一个叫enrollMq444（配置文件中配的）的Queue，并且数据和数据库中的条数一致。
　　

　　3: 从mq中take数据,不详细说了，直接贴配置

　　

        
            
               
            
        
     



   



























public class UpdateSqlSetter implements
ItemPreparedStatementSetter {
@Override
public void setValues(BizArgs bigargs, PreparedStatement ps) throws SQLException {
ps.setString(1, bigargs.getBizTypePropName()+"haha");
ps.setString(2, bigargs.getBizUuid());
}
}　　
4:完了，小试一把。