本程序需要实…

前两天由于项目需要一个windows上的批处理任务kitchen.bat需要接到mq的消息通知后执行为了快速实现这里我们通过springboot写了一个jar程序用于接收mq的消息并调用bat文件。

调用windows的批处理脚本bat并支持传参可根据配置设置并发同时消费多个mq消息调用多个批处理脚本确保java程序能一直正常运行如果有假死或者宕机了可以自动重启批处理脚本执行失败了则再将信息重新放回到mq的队列尾部等待下次执行

用于调用windows服务器命令通过环境变量配置程序运行的参数如mq信息、和执行的批处理脚本命令路径、并发等通过rabbitmq的手工ack来确定消息是否处理成功及并发实现通过actuator来判断java程序是否健康通过windows定时任务来定时检查java程序是否正常提供服务如果不正常则触发重启jar应用通过mavenant打包程序将可执行程序jar及相关脚本打包成一个zip文件方便发给使用方使用

主要实现逻辑

cn.iccboy.kitchen.common;import

lombok.extern.slf4j.Slf4j;import

import

标志1--InputStream2--ErrorStream*/private

static

InputStreamReader(inputStream);BufferedReader

bufferedReader

BufferedReader(inputStreamReader))

{while

e.getMessage());}}).start();}public

static

StrUtil.splicingWithSpace(command,

cmd);int

Runtime.getRuntime().exec(cmd);processStreamHandler(process.getInputStream(),

1);processStreamHandler(process.getErrorStream(),

2);try

{log.error(【异常】process.waitFor:{}

e.getMessage());}log.info(执行命令{},

返回状态码{},

}上面的程序中一定要注意的是process.getErrorStream()

一定要将命令行执行输出的信息输出流和错误信息错误流都从缓冲区读取出来不然会导致程序执行阻塞。

在runtime执行大点的命令中输入流和错误流会不断有流进入存储在JVM的缓冲区中如果缓冲区的流不被读取被填满时就会造成runtime的阻塞。

所以在进行比如大文件复制等的操作时需要不断的去读取JVM中的缓冲区的流防止Runtime的死锁阻塞。

程序健康检查

这里通过actuator来实现首先程序集成actuator,由于是springboot项目所以很方便。

然后通过一个简单的java程序CheckActuator来访问actuator的http地址通过返回值来判断jar程序是否运行正常然后通过windows的脚本checkHealth.bat来调用CheckActuator根据返回值在进行java程序的重启等操作。

pom.xml增加actuator及prome***us的配置

dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-actuator/artifactId/dependencydependencygroupIdio.micrometer/groupIdartifactIdmicrometer-registry-prome***us/artifactId/dependency上的版本会根据springboot对应版本自动集成

配置actuator

management:health:rabbit:enabled:

trueendpoints:web:exposure:include:

[prome***us,health]endpoint:health:show-details:

alwaysmetrics:export:prome***us:enabled:

truejmx:enabled:

当然也可以通过windows的批处理命令直接访问actuator的地址来判断服务是否正常。

/***

该类用于检查程序是否健康通过actuator进行判断是否健康**

public

http://127.0.0.1:8000/actuator/health;if(args

null

args[0];}testUrlWithTimeOut(url);}public

static

url.openConnection();conn.setConnectTimeout(timeOutMillSeconds);conn.connect();InputStream

conn.getInputStream();BufferedReader

reader

sb.toString().contains(HEALTH_FLAG);if(healthFlag)

{System.exit(0);}

e.getMessage());System.exit(1);}}

}我将上面的CheckActuator.java文件放到maven项目的test/java/跟目录下后面会通过ant命令将.class移动到指定位置

上面的springboot项目会通过http服务其运行的端口是8000下面脚本会通过8000端口来获取对应的进程pid

::存活监控

yMd%date:~0,4%-%date:~5,2%-%date:~8,2%

%time:~0,8%

strFile%strPath%log/checkHealth-%date:~0,4%%date:~5,2%%date:~8,2%.log

java

%strPath%%filename%windows定时任务配置

新增-健康检查定时任务.bat

checkBat%strPath%checkHealth.bat

schtasks

pause上面的xxx-health-check是定时任务的名字

/sc

表示每2分钟执行一次命令。

上面是通过命令配置的定时任务也可以通过windows的图形管理界面【计划任务】配置。

移除-健康检查定时任务.bat

${K_PORT:8000}servlet:context-path:

xxxrabbitmq:host:

${K_MQ_HOST:172.18.1.100}password:

${K_MQ_USERNAME:mq}connection-timeout:

15000listener:simple:acknowledge-mode:

manual

每个消费每次预去取几个消息jackson:date-format:

yyyy-MM-dd

${K_BAT_PATHS:C:\invoke.bat}可通过设置系统的环境变量来改变配置可设置的变量包含

变量说明默认值K_PORT程序运行的http服务端口8000K_MQ_HOSTrabbitmq

服务ip172.18.1.100K_MQ_PORTrabbitmq

密码123456K_BAT_PATHSbat脚本路径可以配置多个通过英文逗号分隔配置多个就会启动多个消费者,如C:\invoke_1.bat,C:\invoke_2.batC:\invoke.batK_WORKS每个消费者的并发数。

如K_BAT_PATHS配置了3个命令K_WORKS

这表示有3*26个消费者1

cn.iccboy.kitchen.common.CmdUtil;

import

cn.iccboy.kitchen.common.ThreadUtil;

import

com.rabbitmq.client.MessageProperties;

import

org.springframework.amqp.rabbit.annotation.RabbitListener;

import

org.springframework.amqp.support.AmqpHeaders;

import

org.springframework.messaging.Message;

import

org.springframework.messaging.handler.annotation.Headers;import

java.io.IOException;

java.nio.charset.StandardCharsets;

import

cn.iccboy.kitchen.mq.TopicRabbitMqConfig.EXCHANGE_DATA;

import

cn.iccboy.kitchen.mq.TopicRabbitMqConfig.KEY_INDEX_PROCESS;/***

author

TopicRabbitMqConfig.QUEUE_INDEX_PROCESS)public

void

headers.get(AmqpHeaders.DELIVERY_TAG);try

{log.info([start]第{}执行器,消息内容:{},

seq,

message.getPayload());if(status

{log.info([err_1]第{}执行器,消息内容:{}加工脚本执行异常状态码{},seq,

status);throw

RuntimeException(脚本执行异常);}log.info([end]第{}执行器执行完成:{},

seq,

{ThreadUtil.sleep(1000);log.error([err]第{}执行器,执行异常重新进入队列:{},

seq,

e);//channel.basicNack(deliveryTag,

false,

将处理错误的消息放到重新队列尾部channel.basicPublish(EXCHANGE_DATA,KEY_INDEX_PROCESS,

MessageProperties.PERSISTENT_TEXT_PLAIN,

message.getPayload().getBytes(StandardCharsets.UTF_8));}

finally

确认已处理channel.basicAck(deliveryTag,false);}}}

package

org.springframework.beans.MutablePropertyValues;

import

org.springframework.beans.factory.support.BeanDefinitionRegistry;

import

org.springframework.beans.factory.support.RootBeanDefinition;

import

org.springframework.context.EnvironmentAware;

import

org.springframework.context.annotation.Configuration;

import

org.springframework.context.annotation.Import;

import

org.springframework.context.annotation.ImportBeanDefinitionRegistrar;

import

org.springframework.core.env.Environment;

import

org.springframework.core.type.AnnotationMetadata;import

java.util.List;Slf4j

Import(DynamicBuildMqReceiveBean.ImportConfig.class)

public

environment.getProperty(shell.paths,

List.class);}

registerBeanDefinitions(AnnotationMetadata

registry)

RootBeanDefinition();beanDefinition.setBeanClass(CmdMqReceive.class);MutablePropertyValues

values

MutablePropertyValues();values.addPropertyValue(batPath,

batPath);values.addPropertyValue(seq,

seq);beanDefinition.setPropertyValues(values);registry.registerBeanDefinition(CmdMqReceive.class.getName()

seq,

}上面通过ImportBeanDefinitionRegistrar的方式

pom.xml文件中增加如下配置

buildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactId/pluginplugingroupIdorg.apache.maven.plugins/groupIdartifactIdmaven-antrun-plugin/artifactIdversion1.8/versionexecutionsexecutionidclean/idphaseclean/phaseconfigurationtargetdelete

file${basedir}/shell/CheckActuator.class//target/configurationgoalsgoalrun/goal/goals/executionexecutionidtest-compile/idphasetest-compile/phaseconfigurationtargetcopy

overwritetrue

file${project.build.directory}/test-classes/CheckActuator.classtodir${basedir}/shell

//target/configurationgoalsgoalrun/goal/goals/executionexecutionidpackage/idphasepackage/phaseconfigurationtargetdelete

dir${project.build.directory}/kitchen-mq-bin/mkdir

dir${project.build.directory}/kitchen-mq-bin/copy

todir${project.build.directory}/kitchen-mq-bin

overwritetruefileset

file${project.build.directory}/${project.name}-${project.version}.jar

todir${project.build.directory}/kitchen-mq-bin

/zip

destfile${basedir}/kitchen-mq-bin.zipfileset

dir${project.build.directory}/kitchen-mq-bininclude

name*//fileset/zip/target/configurationgoalsgoalrun/goal/goals/execution/executions/plugin/plugins/build项目结构如下图

获取执行包

package上面命令执行完成后在项目的跟目录会产生一个压缩包kitchen-mq-bin.zip,将压缩包直接拷贝到目标服务器解压即可。

解压后直接执行新增-健康检查定时任务.bat即可。

2分钟后就会启动程序。