解压apache-activemq-5.13.3-bin 后 运行D:\apache-activemq-5.13.3\bin\win64\activemq 时报错，咋解

Posted 2023-04-18

安装环境：linux redhat
activemq版本：5.8.0
1.从http://activemq.apache.org/download.html地址下载apache-activemq-5.8.0-bin.tar.gz包
2.解压缩到指定的目录
tar zxvf apache-activemq-5.8.0-bin.tar.gz -C /usr/local
解压缩后会在/usr/local下生成apache-activemq-5.8.0目录，其中bin目录下就是activeMQ的执行脚本存在的位置了。
3.如果启动脚本无法执行，我们需要修改一下权限
cd /usr/local/apache-activemq-5.8.0/bin
chmod 775 activemq
4.设置activeMQ配置环境.activemqrc
bin/activemq setup ~/.activemqrc
5.启动activeMQ
在activemq主目录键入如下命令：
bin/activemq start
然后会看到控制台日志输出如下：
INFO: Loading \'/home/chenzhou/.activemqrc\'
INFO: Using java \'/usr/java/jdk1.6.0_03/bin/java\'
INFO: Starting - inspect logfiles specified in logging.properties and log4j.properties to get details
INFO: pidfile created : \'/usr/local/apache-activemq-5.8.0/data/activemq-localhost.localdomain.pid\' (pid \'18567\')
我们也可以把日志输出到指定的日志文件中
bin/activemq start > /tmp/smlog 2>&1 &
然后日志就输出到/tmp/smlog文件中了
注意：官方文档中标明了如果按上述的方式启动后，如果我们把linux终端窗口关闭的话，则服务也会停止
具体如下：
不过，我尝试了一下关闭xshell终端，貌似服务依然正在，没有退出。
不过为了保险起见，我们在启动时最好还是加上nohup参数
启动命令如下：
nohup bin/activemq start
或者：
nohup bin/activemq start > /tmp/smlog 2>&1 &
查看启动情况：
通过端口查询，activeMQ默认配置下启动会启动8161和61616两个端口，其中8161是mq自带的管理后台的端口，61616是mq服务默认端口：
netstat -ntlp|grep 8161
netstat -an|grep 61616
访问activeMQ管理界面，http://ip:8161/admin，如果是本机就是http://localhost:8161/admin追问

我使用的电脑是windows 64位系统

参考技术A 是不是和你的系统版本不匹配，你换成32位试试追问

已经解决了这个是 jdk版本问题，5.13的activemq 默认启动时启用的是1.7的版本，我的是1.6

springbatch apache-activemq 整合（往mq中put数据，从mq中take数据）

简单测试如下：

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数据

配置如下：

<job id="jmsReadJob">
        <step id="jmsReadStep">
            <tasklet transaction-manager="transactionManager">
                <chunk reader="jmsItemReader" processor="creditBillProcessor" writer="creditItemWriter" commit-interval="2"></chunk>
            </tasklet>
        </step>
 </job>

      <!-- 从数据库读取 -->
     <bean:bean id="jmsItemReader" scope="step"
        class="org.springframework.batch.item.database.JdbcCursorItemReader" >
        <bean:property name="dataSource" ref="dataSource"/>
<bean:property name="sql" 
        value="
        select BIZ_UUID,BIZ_TYPE_CODE,BIZ_TYPE_PROP_CODE,BIZ_TYPE_PROP_NAME from IMS_BIZ_ARGS
        "/>
        <bean:property name="rowMapper">
            <bean:bean class="org.springframework.jdbc.core.BeanPropertyRowMapper">
                <bean:property name="mappedClass" value="com.citiccard.channel.sts.mqbatch.BizArgs"/>
            </bean:bean>
        </bean:property>
    </bean:bean>

 <!-- 写到MQ中 -->

<bean:bean id="creditItemWriter" class="org.springframework.batch.item.jms.JmsItemWriter">
<bean:property name="jmsTemplate" ref="jmsTemplate" />
</bean:bean>

 <!-- MQ对象配置 -->

<bean:bean id="jmsTemplate"  class="org.springframework.jms.core.JmsTemplate">
<bean:property name="connectionFactory" ref="mqfactory" />
<bean:property name="messageConverter">
<bean:bean
class="org.springframework.jms.support.converter.SimpleMessageConverter" />
</bean:property> 
<bean:property name="defaultDestination" ref="destination" />
<bean:property name="receiveTimeout" value="500" />
</bean:bean>

<bean:bean id="mqfactory" class="org.apache.activemq.ActiveMQConnectionFactory" >
<bean:property name="brokerURL" value="tcp://localhost:61616" />
<bean:property name="trustAllPackages" value="true" />
<bean:property name="useAsyncSend" value="true" />
<bean:property name="redeliveryPolicy">
<bean:bean class="org.apache.activemq.RedeliveryPolicy">
<bean:property name="maximumRedeliveries" value="0" />
</bean:bean>
</bean:property>
</bean:bean>

<bean:bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
 <!-- MQ队列名称（MQ服务器中可以有多个队列）-->
<bean:constructor-arg value="enrollMq444" />
</bean:bean>

 <!-- 处理器（意思就是你从源中取到数据后，这些数据是否要加工一下（比如我根据这个数据发一个socket请求或者我把某个字段的值乘以2等等））-->
<bean:bean id="creditBillProcessor" scope="step"
class="com.citiccard.channel.sts.mqbatch.CreditBillProcessor">
</bean:bean>

<!-- 我这个测试的例子的意思是：我从数据库中把对象取出来啥没干直接把对象发送给springbatch的creditItemWriter对象
也就是说MQ中存放的是BizArgs对象。这也意味着我从MQ中取数据时数据是个BizArgs对象而不是String
什么的其他的对象。
当然我也可以toString一下玩玩，测试么。
-->
public class CreditBillProcessor implements ItemProcessor<BizArgs, BizArgs> {
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数据,不详细说了，直接贴配置

<bean:import resource="classpath:springJob/job-context.xml" />

<job id="jmsReadJob">
        <step id="jmsReadStep">
            <tasklet transaction-manager="transactionManager">
                <chunk reader="jmsItemReader" processor="creditBillProcessor" writer="creditItemWriter" commit-interval="2"></chunk>
            </tasklet>
        </step>
    </job>

 <bean:bean id="jmsItemReader"
class="org.springframework.batch.item.jms.JmsItemReader">
<bean:property name="itemType" value="com.citiccard.channel.sts.mqbatch.BizArgs"/>
<bean:property name="jmsTemplate" ref="jmsTemplate"/>
</bean:bean>
    <bean:bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate" >
<bean:property name="connectionFactory" ref="mqfactory" />
<bean:property name="messageConverter">
<bean:bean
class="org.springframework.jms.support.converter.SimpleMessageConverter" />
</bean:property> 
<bean:property name="defaultDestination" ref="destination" />
<bean:property name="receiveTimeout" value="500" />
</bean:bean>

<bean:bean class="org.apache.activemq.ActiveMQConnectionFactory" id="mqfactory">
<bean:property name="brokerURL" value="tcp://localhost:61616" />
<bean:property name="trustAllPackages" value="true" />
</bean:bean>
<bean:bean id="destination2" class="org.apache.activemq.command.ActiveMQQueue">
<bean:constructor-arg value="enroll" />
</bean:bean>
<bean:bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
<bean:constructor-arg value="enrollMq444" />
</bean:bean>

<bean:bean id="creditBillProcessor" scope="step"
class="com.citiccard.channel.sts.mqbatch.GetCreditBillProcessor">
</bean:bean>
<!-- 写数据库 -->
<bean:bean id="creditItemWriter"
class="org.springframework.batch.item.database.JdbcBatchItemWriter"
scope="step">
<bean:property name="dataSource" ref="w" />
<bean:property name="sql"
value="update  IMS_BIZ_ARGS t  set t.BIZ_TYPE_PROP_NAME = ? where   t.BIZ_UUID  = ? " />
<bean:property name="itemPreparedStatementSetter">
<bean:bean
class="com.citiccard.channel.sts.mqbatch.UpdateSqlSetter" />
</bean:property>
</bean:bean>
</bean:beans>

<!-- 我把name值加了一个haha,哈哈哈 -->
public class UpdateSqlSetter implements
ItemPreparedStatementSetter<BizArgs> {
@Override
public void setValues(BizArgs bigargs, PreparedStatement ps) throws SQLException {
ps.setString(1, bigargs.getBizTypePropName()+"haha");
ps.setString(2, bigargs.getBizUuid());
}
}

4:完了，小试一把。