From eeb3c6c5fe6a4c5d6a2b4ea7ddd38f723af6156e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=EA=B0=95=EC=84=9D=20=EC=B5=9C?= Date: Fri, 24 Feb 2023 11:51:34 +0900 Subject: [PATCH] =?UTF-8?q?=EC=84=B8=EC=85=98=ED=81=B4=EB=9F=AC=EC=8A=A4?= =?UTF-8?q?=ED=84=B0=EB=A7=81=20=EC=9E=91=EC=97=85=EC=A4=91.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../TomcatClusterContextCustomizer.java | 37 +++++++++++++++---- .../resources/application-test1.properties | 11 +++--- .../resources/application-test2.properties | 9 +++-- .../resources/application-was1.properties | 12 +++--- .../resources/application-was2.properties | 12 +++--- 5 files changed, 52 insertions(+), 29 deletions(-) diff --git a/src/main/java/com/dbnt/faisp/config/tomcat/TomcatClusterContextCustomizer.java b/src/main/java/com/dbnt/faisp/config/tomcat/TomcatClusterContextCustomizer.java index 0c07f239..5a4e2644 100644 --- a/src/main/java/com/dbnt/faisp/config/tomcat/TomcatClusterContextCustomizer.java +++ b/src/main/java/com/dbnt/faisp/config/tomcat/TomcatClusterContextCustomizer.java @@ -23,6 +23,7 @@ import org.springframework.stereotype.Component; @Component public class TomcatClusterContextCustomizer implements TomcatContextCustomizer { +/* @Value("${tomcat.cluster.static-member-host:}") private String staticMemberHost; @@ -36,6 +37,7 @@ public class TomcatClusterContextCustomizer implements TomcatContextCustomizer { private Integer receiverPort; @Value("${tomcat.cluster.receiver-max-threads:}") private Integer receiverMaxThreads; +*/ @Override public void customize( final Context context ) { @@ -51,40 +53,59 @@ public class TomcatClusterContextCustomizer implements TomcatContextCustomizer { private void configureCluster(Engine engine) { //cluster setting SimpleTcpCluster cluster = new SimpleTcpCluster(); +/* cluster.setChannelStartOptions(3); cluster.setChannelSendOptions(8); //channel setting GroupChannel channel = new GroupChannel(); - StaticMembershipInterceptor interceptor = new StaticMembershipInterceptor(); + StaticMembershipInterceptor interceptor = new StaticMembershipInterceptor(); // 대상 정보 StaticMember staticMember = new StaticMember(); - staticMember.setHost(staticMemberHost); staticMember.setPort(staticMemberPort); staticMember.setSecurePort(-1); + staticMember.setHost(staticMemberHost); staticMember.setUniqueId(staticMemberUniqueId); interceptor.addStaticMember(staticMember); //receiver(현재 자신의 정보) NioReceiver receiver = new NioReceiver(); receiver.setAddress(receiverAddress); - receiver.setPort(receiverPort); receiver.setMaxThreads(receiverMaxThreads); + receiver.setPort(receiverPort); + channel.setChannelReceiver(receiver); + channel.addInterceptor(interceptor); + */ + + cluster.setChannelSendOptions(6); + + //channel + GroupChannel channel = new GroupChannel(); + //membership setting + McastService mcastService = new McastService(); + mcastService.setAddress("228.0.0.4"); + mcastService.setPort(45564); // TCP&UDP port 오픈 필요 + mcastService.setFrequency(500); + mcastService.setDropTime(3000); + channel.setMembershipService(mcastService); + + //receiver + NioReceiver receiver = new NioReceiver(); + receiver.setAddress("auto"); + receiver.setMaxThreads(6); + receiver.setPort(5000); // TCP port 오픈 필요 channel.setChannelReceiver(receiver); - channel.addInterceptor(interceptor); - - //sender setting + //sender ReplicationTransmitter sender = new ReplicationTransmitter(); sender.setTransport(new PooledParallelSender()); channel.setChannelSender(sender); - //interceptor setting + //interceptor channel.addInterceptor(new TcpPingInterceptor()); channel.addInterceptor(new TcpFailureDetector()); channel.addInterceptor(new MessageDispatchInterceptor()); - cluster.addValve(new ReplicationValve()); cluster.addValve(new JvmRouteBinderValve()); cluster.setChannel(channel); diff --git a/src/main/resources/application-test1.properties b/src/main/resources/application-test1.properties index ff740e22..78da982f 100644 --- a/src/main/resources/application-test1.properties +++ b/src/main/resources/application-test1.properties @@ -1,14 +1,15 @@ #tomcat tomcat.ajp.protocol=HTTP/1.1 +#tomcat.ajp.protocol=AJP/1.3 logging.level.org.apache.tomcat: DEBUG logging.level.org.apache.catalina: DEBUG tomcat.cluster.enabled=true -tomcat.cluster.static-member-host=172.80.0.3 -tomcat.cluster.static-member-port=4040 -tomcat.cluster.static-member-unique-id={0,0,0,0,0,0,0,0,0,0,0,0,0,0,1,2} -tomcat.cluster.receiver-address=172.80.0.2 -tomcat.cluster.receiver-port=4040 +tomcat.cluster.static-member-host=118.219.150.34 +tomcat.cluster.static-member-port=50542 +tomcat.cluster.static-member-unique-id={0,0,0,0,0,0,0,0,0,0,0,0,0,0,1,1} +tomcat.cluster.receiver-address=118.219.150.34 +tomcat.cluster.receiver-port=50540 tomcat.cluster.receiver-max-threads=4 #file upload diff --git a/src/main/resources/application-test2.properties b/src/main/resources/application-test2.properties index af7e0070..6da8f9d2 100644 --- a/src/main/resources/application-test2.properties +++ b/src/main/resources/application-test2.properties @@ -1,14 +1,15 @@ #tomcat tomcat.ajp.protocol=HTTP/1.1 +#tomcat.ajp.protocol=AJP/1.3 logging.level.org.apache.tomcat: DEBUG logging.level.org.apache.catalina: DEBUG tomcat.cluster.enabled=true -tomcat.cluster.static-member-host=172.80.0.2 -tomcat.cluster.static-member-port=4040 +tomcat.cluster.static-member-host=118.219.150.34 +tomcat.cluster.static-member-port=50540 tomcat.cluster.static-member-unique-id={0,0,0,0,0,0,0,0,0,0,0,0,0,0,1,1} -tomcat.cluster.receiver-address=172.80.0.3 -tomcat.cluster.receiver-port=4040 +tomcat.cluster.receiver-address=118.219.150.34 +tomcat.cluster.receiver-port=50542 tomcat.cluster.receiver-max-threads=4 #file upload diff --git a/src/main/resources/application-was1.properties b/src/main/resources/application-was1.properties index 4a29186e..943d27a3 100644 --- a/src/main/resources/application-was1.properties +++ b/src/main/resources/application-was1.properties @@ -1,12 +1,12 @@ #tomcat tomcat.ajp.protocol=AJP/1.3 tomcat.cluster.enabled=true -#tomcat.cluster.static-member-host=10.187 -#tomcat.cluster.static-member-port=50540 -#tomcat.cluster.static-member-unique-id={0,0,0,0,0,0,0,0,0,0,0,0,0,0,1,2} -#tomcat.cluster.receiver-address=118.219.150.34 -#tomcat.cluster.receiver-port=4042 -#tomcat.cluster.receiver-max-threads=4 +tomcat.cluster.static-member-host=10.187 +tomcat.cluster.static-member-port= +tomcat.cluster.static-member-unique-id={0,0,0,0,0,0,0,0,0,0,0,0,0,0,1,2} +tomcat.cluster.receiver-address=10.187 +tomcat.cluster.receiver-port= +tomcat.cluster.receiver-max-threads= #file upload spring.servlet.multipart.location=/backup/faisp/uploadFiles diff --git a/src/main/resources/application-was2.properties b/src/main/resources/application-was2.properties index 5a70d4cb..f46ecd6d 100644 --- a/src/main/resources/application-was2.properties +++ b/src/main/resources/application-was2.properties @@ -1,12 +1,12 @@ #tomcat tomcat.ajp.protocol=AJP/1.3 tomcat.cluster.enabled=true -#tomcat.cluster.static-member-host=118.219.150.34 -#tomcat.cluster.static-member-port=50540 -#tomcat.cluster.static-member-unique-id={0,0,0,0,0,0,0,0,0,0,0,0,0,0,1,1} -#tomcat.cluster.receiver-address=118.219.150.34 -#tomcat.cluster.receiver-port=4042 -#tomcat.cluster.receiver-max-threads=4 +tomcat.cluster.static-member-host=10.187 +tomcat.cluster.static-member-port= +tomcat.cluster.static-member-unique-id={0,0,0,0,0,0,0,0,0,0,0,0,0,0,1,1} +tomcat.cluster.receiver-address=10.187 +tomcat.cluster.receiver-port= +tomcat.cluster.receiver-max-threads= #file upload spring.servlet.multipart.location=/backup/faisp/uploadFiles