Spring boot隨機(jī)端口你都不會(huì)還怎么動(dòng)態(tài)擴(kuò)容
一般情況下每個(gè)spring boot工程啟動(dòng)都有固定的端口,但是固定端口不利用服務(wù)的動(dòng)態(tài)擴(kuò)容,如果在一臺(tái)服務(wù)器上需要對(duì)同一個(gè)服務(wù)進(jìn)行多實(shí)例部署,很容易出現(xiàn)端口沖突,那么怎么解決這個(gè)問題呢?
random隨機(jī)端口
在spring boot中,可以通過${random}來生成隨機(jī)數(shù)字,我們可以在配置文件中,這么設(shè)置端口:
server.port=${random.int(2000,8000)}
通過random.int方法,指定生成2000~8000的隨機(jī)端口。這樣每次啟動(dòng)的端口都不一樣。
多次啟動(dòng),發(fā)現(xiàn)每次的端口都不一致說明配置成功。
注意事項(xiàng):
這里需要注意spring boot項(xiàng)目啟動(dòng)屬性文件的加載順序,spring boot的屬性是由里向外加載,所以最外層的最后被加載,會(huì)覆蓋里層的屬性。
所以如果主動(dòng)在啟動(dòng)命令中使用–server.port配置了項(xiàng)目的端口號(hào),那么屬性文件中配置的隨機(jī)端口屬性就不會(huì)生效。
通過System.setProperty設(shè)置有效隨機(jī)端口
上面的方法雖然暫時(shí)達(dá)到了想要的效果,但是有個(gè)問題:如果生成的這個(gè)隨機(jī)端口已經(jīng)被使用了,那么項(xiàng)目啟動(dòng)就會(huì)出現(xiàn)端口沖突。
那么,我們能否通過一個(gè)檢測(cè)機(jī)制,讓生成的隨機(jī)端口一定是一個(gè)沒有被占用的有效的隨機(jī)端口呢?
有效端口檢測(cè)原理:
通過建立socket連接,Socket socket = new Socket(Address,port);#address代表主機(jī)的IP地址,port代表端口號(hào)
如果對(duì)該主機(jī)的特定端口號(hào)能建立一個(gè)socket,則說明該主機(jī)的該端口在使用。
Socket socket = new Socket(Address,port);#address代表主機(jī)的IP地址,port代表端口號(hào)
如果對(duì)該主機(jī)的特定端口號(hào)能建立一個(gè)socket,則說明該主機(jī)的該端口在使用。
實(shí)現(xiàn)思路:
通過在項(xiàng)目啟動(dòng)前,獲取有效的隨機(jī)端口并通過System.setProperty將變量設(shè)置到系統(tǒng)的全局變量中,這樣項(xiàng)目啟動(dòng)時(shí)就可以從全局變量中獲取到server.port變量的值。
這里的system,系統(tǒng)指的是 JRE (runtime)system,即設(shè)置jvm運(yùn)行時(shí)的全局變量。
工具類:
@Slf4j public class NetUtils { /** * 測(cè)試本機(jī)端口是否被使用 * @param port * @return */ public static boolean isLocalPortUsing(int port){ boolean flag = true; try { //如果該端口還在使用則返回true,否則返回false,127.0.0.1代表本機(jī) flag = isPortUsing("127.0.0.1", port); } catch (Exception e) { } return flag; } /*** * 測(cè)試主機(jī)Host的port端口是否被使用 * @param host * @param port * @throws UnknownHostException */ public static boolean isPortUsing(String host,int port) { boolean flag = false; try { InetAddress Address = InetAddress.getByName(host); Socket socket = new Socket(Address,port); //建立一個(gè)Socket連接 flag = true; } catch (IOException e) { //log.info(e.getMessage(),e); } return flag; } //start--end是所要檢測(cè)的端口范圍 static int start=0; static int end=1024; /** * 由于本機(jī)上安裝了mysql,采用3306端口去驗(yàn)證 * @param args */ public static void main(String args[]){ int testPost =3306; if(isLocalPortUsing(testPost)){ System.out.println("端口 "+testPost+" 已被使用"); }else{ System.out.println("端口 "+testPost+"未使用"); } } }
public class ServerPortUtils { /** * 獲取可用端口 * @return */ public static int getAvailablePort(){ int max = 65535; int min = 2000; Random random = new Random(); int port = random.nextInt(max)%(max-min +1) + min; boolean using = NetUtils.isLocalPortUsing(port); if(using){ return getAvailablePort(); }else{ return port; } } }
項(xiàng)目啟動(dòng)前設(shè)置server.port環(huán)境變量
/** * 開始命令 */ @Slf4j public class StartCommand { public StartCommand(String[] args){ Boolean isServerPort = false; String serverPort = ""; if(args != null){ for (String arg:args){ if(StringUtils.hasText(arg) && arg.startsWith("--server.port") ){ isServerPort = true; serverPort = arg; break; } } } //沒有指定端口,則隨機(jī)生成一個(gè)可用的端口 if(!isServerPort){ int port = ServerPortUtils.getAvailablePort(); log.info("current server.port=" + port); System.setProperty("server.port",String.valueOf(port)); }else{//指定了端口,則以指定的端口為準(zhǔn) log.info("current server.port=" + serverPort.split("=")[1]); System.setProperty("server.port",serverPort.split("=")[1]); } } }
啟動(dòng)類調(diào)用方法:
@SpringBootApplication @EnableUserClient @RestController public class DemoApplication { @Autowired Environment environment; public static void main(String[] args) { new StartCommand(args); SpringApplication.run(DemoApplication.class, args); } }
通過自定義PropertiesPropertySource屬性源實(shí)現(xiàn)
public class MyEnvironmentPostProcessor implements EnvironmentPostProcessor { @Override public void postProcessEnvironment(ConfigurableEnvironment environment, SpringApplication application) { //MapPropertySource Properties properties = new Properties(); properties.put("server.port", ServerPortUtils.getAvailablePort()); System.out.println(properties.get("server.port")); PropertiesPropertySource source = new PropertiesPropertySource("myCustom", properties); environment.getPropertySources().addLast(source); //environment.getPropertySources().addAfter(); } }
通過配置在resources/META-INF/spring.factories文件中使用全名注冊(cè)
org.springframework.boot.env.EnvironmentPostProcessor=com.laowan.demo.command.MyEnvironmentPostProcessor
這樣在項(xiàng)目啟動(dòng)后,就會(huì)將該屬性源加載到Environment中。
總結(jié)
1、為什么要設(shè)置隨機(jī)端?主要是為了解決動(dòng)態(tài)擴(kuò)容時(shí)出現(xiàn)端口沖突的問題。
2、怎么獲取一個(gè)有效的隨機(jī)端口號(hào)
3、spring boot下實(shí)現(xiàn)隨機(jī)端口的三種方式。關(guān)于方式三的自定義屬性源的實(shí)現(xiàn)方式可以多多品味,實(shí)踐一下,更好的體會(huì)屬性文件的加載順序。
到此這篇關(guān)于Spring boot隨機(jī)端口你都不會(huì)還怎么動(dòng)態(tài)擴(kuò)容的文章就介紹到這了,更多相關(guān)Spring boot隨機(jī)端口內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Spring框架接入單機(jī)Redis兩種實(shí)現(xiàn)方式解析
這篇文章主要介紹了Spring框架接入單機(jī)Redis兩種實(shí)現(xiàn)方式解析,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-09-09詳解利用SpringCloud搭建一個(gè)最簡(jiǎn)單的微服務(wù)框架
這篇文章主要介紹了詳解利用SpringCloud搭建一個(gè)最簡(jiǎn)單的微服務(wù)框架,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-11-11java簡(jiǎn)單實(shí)現(xiàn)復(fù)制 粘貼 剪切功能代碼分享
本文給大家分享了一段java編寫的簡(jiǎn)單實(shí)現(xiàn)復(fù)制粘貼剪切功能的代碼,需要的小伙伴可以直接拿走使用。如有更好的方案,也可以告之本人。2014-11-11MybatisPlus?構(gòu)造器wrapper的使用與原理解析
本次我們介紹了MybatisPlus?構(gòu)造器wrapper的使用方式及其易錯(cuò)點(diǎn),同時(shí)也針對(duì)其運(yùn)行的原理進(jìn)行了解釋,只有深刻理解了它的原理,我們才能更靈活的使用,并且更快的排查出問題,感興趣的朋友跟隨小編一起看看吧2024-05-05java實(shí)現(xiàn)學(xué)生宿舍系統(tǒng)
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)學(xué)生宿舍系統(tǒng),文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-03-03