java實(shí)現(xiàn)Linux(centos) 中docker容器下命令交互的代碼（配置向?qū)В?/h1>

瀏覽：63日期：2022-08-12 17:11:22

開(kāi)發(fā)需求: 因系統(tǒng)程序部署時(shí),經(jīng)常是拆分部署(多臺(tái)機(jī)器) ,手工部署費(fèi)時(shí)費(fèi)力,且每次都要手工配置系統(tǒng)參數(shù)(系統(tǒng)提供配置向?qū)?。

如下圖所示:

1)進(jìn)行main容器 -> 2)執(zhí)行系統(tǒng)配置向?qū)?-> 3)選擇服務(wù)器模式 -> 4) 選擇web控制臺(tái)....然后進(jìn)行具體的服務(wù)器IP設(shè)置。

為了解放雙手，用java實(shí)現(xiàn)了Linux(centos) 下docker 應(yīng)用程序的命令交互。

具體代碼如下:

import java.io.*; /** * @author by dujiajun * @date 2021/4/29. */public class TestMain extends Thread{ //進(jìn)入docker main private static String [] cmds = {'docker','exec','-i','main','bash'}; private Process pro; //初始化各機(jī)器IP信息 private String role = ''; private String webIp = ''; private String redisIp = ''; private String beanstalkdIp = ''; private String pgIp = ''; //main應(yīng)用重啟 public static String [] cmdRestart = {'/bin/sh','-c','docker restart main'}; public void cmdRun(String[] machines) throws Exception {//執(zhí)行xx系統(tǒng)配置向?qū)畈⑸蛇M(jìn)程//pro = Runtime.getRuntime().exec(cmds);ProcessBuilder pb = new ProcessBuilder(cmds); /* pb.inheritIO();pb.redirectErrorStream(true);*/pro = pb.start();System.out.println('執(zhí)行前pro1:' + pro.isAlive()); //解析machines信息if (machines.length > 0) { for (int i = 0; i < machines.length; i++) {int strEndIndex = machines[i].indexOf(':');String str = machines[i].substring(0, strEndIndex);String content = machines[i].substring(strEndIndex + 1);switch (str.trim()) { case 'role':role = content;break; //web服務(wù)器IP case 'webIp':webIp = content;break; //redis服務(wù)器IP case 'redisIp':redisIp = content;break; //redis服務(wù)器IP case 'beanstalkdIp':beanstalkdIp = content;break; //beanstalkd服務(wù)器IP case 'pgIp':pgIp = content;break; //beanstalkd服務(wù)器IP default:break;} }} new Thread() { public void run() {try (BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(pro.getOutputStream()))) { if (role != null && role.equals('web-server')) {//系統(tǒng)web控制臺(tái)System.out.println('*********進(jìn)入web控制臺(tái)配置向?qū)?********');//系統(tǒng)配置向?qū)罴?webString[] strCmdWeb = {'python /opt/tools/skylar_cli/bin/skylar_cli.pyc',//系統(tǒng)配置向?qū)?server-type', //服務(wù)器模式'web-server', //管理服務(wù)器:提供管理功能及應(yīng)用功能'allow-deploy-api-server 0', //設(shè)置是否允許部署應(yīng)用服務(wù)器 1允許 0不允許'cache-info ' + redisIp + ':6379', //緩存服務(wù)器'db-info ' + pgIp + ':5432', //設(shè)置數(shù)據(jù)庫(kù)信息'queue-info ' + beanstalkdIp + ':11300', //設(shè)置隊(duì)列信息'report-server-db-info ' + pgIp + ':5432', //設(shè)置報(bào)表數(shù)據(jù)庫(kù)'sfmg-db-info ' + pgIp + ':5432', //設(shè)置軟件管家數(shù)據(jù)庫(kù)'web-server-port ' + webIp + ':8080',//設(shè)置管理服務(wù)器端口'commit',//提交'exit'}; //查看進(jìn)程是否還存活System.out.println('執(zhí)行前pro2:' + pro.isAlive());for (String strWeb : strCmdWeb) { synchronized (bw) {bw.write(strWeb.trim());bw.newLine();System.out.println('step: ' + strWeb);bw.wait(1000); }} //查看進(jìn)程是否還存活System.out.println('pro3:' + pro.isAlive());bw.flush();//緩存提交System.out.println('緩存提交!');bw.close();System.out.println(' bw.close();');System.out.println('web配置向?qū)гO(shè)置成功!'); } else if (role != null && role.equals('api-server')) {//系統(tǒng)app應(yīng)用//系統(tǒng)配置向?qū)罴?APPSystem.out.println('*********進(jìn)入APP服務(wù)器控制臺(tái)配置向?qū)?********');String[] strCmdApp = {'python /opt/tools/skylar_cli/bin/skylar_cli.pyc',//系統(tǒng)配置向?qū)?server-type', //服務(wù)器模式'api-server', //APP服務(wù)器'cache-info ' + redisIp + ':6379', //緩存服務(wù)器'db-info ' + pgIp + ':5432', //設(shè)置數(shù)據(jù)庫(kù)信息'queue-info ' + beanstalkdIp + ':11300', //設(shè)置隊(duì)列信息'web-server-info ' + webIp + ':8080', //設(shè)置管理服務(wù)器端口'commit',//提交配置'exit'}; for (String str : strCmdApp) { synchronized (bw) {bw.write(str.trim());bw.newLine();System.out.println('step: ' + str);bw.wait(1000); }}//查看進(jìn)程是否還存活System.out.println('pro3:' + pro.isAlive());bw.flush();//緩存提交System.out.println('緩存提交!');System.out.println('app配置向?qū)гO(shè)置成功!');bw.close(); } else if (role != null && role.equals('log-analyze-server')) {//系統(tǒng)日志分析服務(wù)器//系統(tǒng)配置向?qū)罴?log-analyze-serverSystem.out.println('*********進(jìn)入日志分析服務(wù)器控制臺(tái)配置向?qū)?********');String[] strCmdLog = {'python /opt/tools/skylar_cli/bin/skylar_cli.pyc',//天擎配置向?qū)?server-type', //服務(wù)器模式'log-analyze-server', //管理服務(wù)器:提供管理功能及應(yīng)用功能'cache-info ' + redisIp + ':6379', //緩存服務(wù)器'db-info ' + pgIp + ':5432', //設(shè)置數(shù)據(jù)庫(kù)信息'queue-info ' + beanstalkdIp + ':11300', //設(shè)置隊(duì)列信息'web-server-info ' + webIp + ':8080', //設(shè)置管理服務(wù)器端口'sfmg-db-info ' + pgIp + ':5432', //設(shè)置軟件管家數(shù)據(jù)庫(kù)'commit',//提交配置'exit' }; //順序執(zhí)行配置向?qū)頵or (String str : strCmdLog) { synchronized (bw) {bw.write(str.trim());bw.newLine();System.out.println('step: ' + str);bw.wait(1000); }}//測(cè)試進(jìn)程是否還存活System.out.println('pro3:' + pro.isAlive());bw.flush();//緩存提交System.out.println('緩存提交!');System.out.println('日志分析服務(wù)器配置向?qū)гO(shè)置成功!');bw.close(); } } catch (IOException | InterruptedException e) { //pro.destroyForcibly(); e.printStackTrace(); //pro.destroy(); System.out.println('e.getMessage(): ' + e.getMessage());} finally { try {Process process = Runtime.getRuntime().exec(cmdRestart);//重啟mainSystem.out.println('process.isAlive:' + process.isAlive());System.out.println('重啟main成功!'); } catch (IOException e) {e.printStackTrace(); }} }}.start(); new Thread(){ public void run(){BufferedReader br = new BufferedReader(new InputStreamReader(pro.getErrorStream()));String cmdout = '';try { cmdout = br.readLine(); while(cmdout!= null&&(!cmdout.equals('exit'))){System.out.println(cmdout); }} catch (IOException e) { //System.out.println('br:pro.destroy();'); //pro.destroy(); e.printStackTrace(); System.out.println('e.printStackTrace();');}try { System.out.println(' br.close();'); br.close();} catch (IOException e) { e.printStackTrace();} }}.start();pro.waitFor();//進(jìn)程等待 } public static void main(String[] args) throws Exception { TestMain testMain = new TestMain(); /*//測(cè)試用String[] machines ={'role:web-server','webIp:xx.xx.xx.110','redisIp:xx.xx.xx.211','beanstalkdIp:xx.xx.xx.211','pgIp:xx.xx.xx.212'};*/ testMain.cmdRun(args); /* System.exit(0);System.out.println('System.exit(0);');*/ }}

特別注意:

private static String [] cmds = {'docker','exec','-i','main','bash'};

一定要使用 docker exec -i main bash ，不要使用 -it ，否則會(huì)報(bào)錯(cuò) cannot enable tty mode on non tty input。

Usage: docker exec [OPTIONS] CONTAINER COMMAND [ARG...] Run a command in a running container -i, --interactive=false Keep STDIN open even if not attached -t, --tty=false Allocate a pseudo-TTY

打成jar包，執(zhí)行jar包：

終于看到久違的部署成功界面~

到此這篇關(guān)于java實(shí)現(xiàn)Linux(centos) 中docker容器下命令交互（配置向?qū)В┑奈恼戮徒榻B到這了,更多相關(guān)docker容器命令交互內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！

標(biāo)簽： Java

上一條：Java黑科技之通過(guò)Google Java Style 文件配置IDEA和Ecplise代碼風(fēng)格下一條：Java學(xué)習(xí)筆記之Maven篇

相關(guān)文章：

1. Python3 json模塊之編碼解碼方法講解2. Linux刪除系統(tǒng)自帶版本Python過(guò)程詳解3. Python 制作查詢商品歷史價(jià)格的小工具4. Python 合并拼接字符串的方法5. python 使用事件對(duì)象asyncio.Event來(lái)同步協(xié)程的操作6. ASP基礎(chǔ)知識(shí)VBScript基本元素講解7. ASP.NET MVC使用jQuery ui的progressbar實(shí)現(xiàn)進(jìn)度條8. Python 利用Entrez庫(kù)篩選下載PubMed文獻(xiàn)摘要的示例9. Python sublime安裝及配置過(guò)程詳解10. Python字符串到字節(jié)的轉(zhuǎn)換。雙反斜杠問(wèn)題