如何解决awk通过plink和多个服务器跃点没有响应
为什么awk无法回复文字？我知道我在正确的服务器上（将awk命令/ Object更改为ls -la会返回显示正确信息的文本）。而且我知道awk命令在直接在服务器上运行时可以工作-我可以复制粘贴该命令，它将运行
def tailLogs(Object object){
def cmd = jumperBox() + " " + object
Runtime rt = Runtime.getRuntime()
log.info("Running: "+cmd)
Process process = rt.exec(cmd.toString())
StringBuilder cmdReturn = new StringBuilder()
try{
InputStream inputStream = process.getInputStream()
int c
while ((c = inputStream.read()) != -1) {
cmdReturn.append((char) c)
}
log.info("CMD RESPONSE: "+ cmdReturn)
process.waitFor()
}catch(Exception e){
log.warn(e.getMessage())
}finally{
process.destroy()
}
日志：
2020-08-27 09:21:56.359 INFO serverInformation -Running: plink.exe -batch -ssh user@server1 -i C:\privateKey.ppk ssh user2@server2 -i ~/.ssh/id_rsa awk '$0 >= "2020-08-27 09:06:56,236" && $0 <= "2020-08-27 09:21:56,238"' logfile
2020-08-27 09:21:59.119 INFO serverInformation -CMD RESPONSE:
2020-08-27 09:21:59.147 INFO logTester -2
我查看了以下链接，它们仅提供了帮助，使用流程生成器意味着重写了我不想做的其他功能（我尝试了但失败了，我不知道如何发送多个命令（例如服务器使用-i选项跳。）在看到ls -la的输出后，我对这种解决方案非常满意：（
No response when running AWK shell script using java
Run a remote awk command using ssh
我使用流程生成器将上面的代码更新为以下代码，但是现在我在日志中得到-255 ：(您可以快速了解为什么我不想走这条路线：（
def getLogs(String serverConnection,String serverKey,String fileName){
if(osName.contains('windows')){
ProcessBuilder pb = new ProcessBuilder(ssh(),//this could be plink or straight ssh
"-batch","-ssh","user@server1","-i",server1key(),//changes depending on server
"ssh",serverConnection,serverKey,"awk","'\$0 >= \"${startTime.format(DateTimeFormatter.ofPattern(pattern))}\" && \$0 <= \"${endTime.format(DateTimeFormatter.ofPattern(pattern))}\"'",fileName
)
log.info "running: "+pb.toString() //didnt show me
pb.redirectErrorStream()
Process process = pb.start()
StringBuilder cmdReturn = new StringBuilder()
try{
InputStream inputStream = process.getInputStream()
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))
int c
while ((c = reader.read()) != -1) {
cmdReturn.append((char) c)
}
log.info("CMD RESPONSE: "+ cmdReturn)
process.waitFor()
}catch(Exception e){
log.warn(e.getMessage())
}finally{
process.destroy()
}
}else{
ProcessBuilder pb = new ProcessBuilder("ssh","ssh",fileName
)
pb.redirectErrorStream()
Process process = pb.start()
StringBuilder cmdReturn = new StringBuilder()
try{
InputStream inputStream = process.getInputStream()
int c
while ((c = inputStream.read()) != -1) {
cmdReturn.append((char) c)
}
log.info("CMD RESPONSE: "+ cmdReturn)
process.waitFor()
}catch(Exception e){
log.warn(e.getMessage())
}finally{
process.destroy()
}
}
}
与此相关的日志没有太大不同：
2020-09-02 16:50:54.520 INFO serverInformation -running: java.lang.ProcessBuilder@1c691f9f
2020-09-02 16:50:57.335 INFO serverInformation -CMD RESPONSE:
2020-09-02 16:50:57.346 INFO logTester -255
根据How do I run multiple commands in SSH through Java?，我建立流程的方式是正确的吗？
解决方法
因此，在尝试使用Java \ groovy代码进行许多不同的变化之后，我求助于制作一个bash文件：
#!/bin/bash
while getopts ?s:e:c:k:f: flag
do
case "${flag}" in
s) startTime=${OPTARG};;
e) endTime=${OPTARG};;
c) serverConnection=${OPTARG};;
k) serverKey=${OPTARG};;
f) fileName=${OPTARG};;
\?)echo "This will not work without all options below:
-s startTime format: 2020-08-27 09:06:56,236
-e endTime format: 2020-08-27 09:16:56,236
-c server connection eg: user@server
-k id_rsa file
-f logfile eg: APPLICATION/logs/log.file"
exit;;
esac
done
ssh $serverConnection -i $serverKey "awk '\$0 >= \"$startTime\" && \$0 <= \"$endTime\"' $fileName"
我在PB中通过这种方式称呼它
pb.command(ssh(),//dbl check the environment we are in
"-batch","-ssh","user@server","-i",jumperKey(),//again to dbl check the environment we are in
"./awk.sh","-s",startTime.format(DateTimeFormatter.ofPattern(pattern)).replaceAll(/ /,'\\\\ '),"-e",endTime.format(DateTimeFormatter.ofPattern(pattern)).replaceAll(/ /,"-c",serverConnection,"-k",serverKey,"-f",fileName
)
老实说，对拥有bash文件不满意，但对tempus fugit满意
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。