openshift のいくつかのスプリング機能の機能と構成をチェックするための小さなアプリケーションを作成しています。ここでコードを見つけることができます: https://github.com/Laures/openshift-spring-testapp
現在、openshift にはポートにバインドする機能にいくつかの厳しい制限があるため、Spring 統合の tcp/ip サポートをテストしようとしています。サーバー ソケット部分は単純でした。許可されたポートを選択し、内部サーバー IP (localhost ではありません) を使用します。
クライアント側の部分で失敗しています。パブリック DNS エントリを使用して tcp 接続を開き、サーバーに接続したいと考えています。私が知る限り(以下のスタックトレース)、アプリケーションはサーバーへの発信接続用のローカルソケットを開くことができません。
17:41:36.309 [pool-3-thread-1] DEBUG o.s.i.i.t.c.TcpNetClientConnectionFactory - Opening new socket connection to springtest-laures.rhcloud.com:4444
17:41:36.317 [pool-3-thread-1] ERROR o.s.i.ip.tcp.TcpOutboundGateway - Tcp Gateway exception
java.net.SocketException: Permission denied
at java.net.PlainSocketImpl.socketConnect(Native Method) ~[na:1.7.0_19]
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339) ~[na:1.7.0_19]
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200) ~[na:1.7.0_19]
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182) ~[na:1.7.0_19]
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:391) ~[na:1.7.0_19]
at java.net.Socket.connect(Socket.java:579) ~[na:1.7.0_19]
at java.net.Socket.connect(Socket.java:528) ~[na:1.7.0_19]
at java.net.Socket.<init>(Socket.java:425) ~[na:1.7.0_19]
at java.net.Socket.<init>(Socket.java:208) ~[na:1.7.0_19]
at javax.net.DefaultSocketFactory.createSocket(SocketFactory.java:271) ~[na:1.7.0_19]
at org.springframework.integration.ip.tcp.connection.TcpNetClientConnectionFactory.createSocket(TcpNetClientConnectionFactory.java:89) ~[spring-integration-ip-2.2.3.RELEASE.jar:na]
at org.springframework.integration.ip.tcp.connection.TcpNetClientConnectionFactory.obtainConnection(TcpNetClientConnectionFactory.java:63) ~[spring-integration-ip-2.2.3.RELEASE.jar:na]
at org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory.getConnection(AbstractClientConnectionFactory.java:49) ~[spring-integration-ip-2.2.3.RELEASE.jar:na]
at org.springframework.integration.ip.tcp.TcpOutboundGateway.handleRequestMessage(TcpOutboundGateway.java:116) ~[spring-integration-ip-2.2.3.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:73) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:115) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:102) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:157) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:128) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.core.MessagingTemplate.doSend(MessagingTemplate.java:288) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.core.MessagingTemplate.doSendAndReceive(MessagingTemplate.java:318) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.core.MessagingTemplate.sendAndReceive(MessagingTemplate.java:239) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.core.MessagingTemplate.convertSendAndReceive(MessagingTemplate.java:274) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.gateway.MessagingGatewaySupport.doSendAndReceive(MessagingGatewaySupport.java:224) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.gateway.MessagingGatewaySupport.sendAndReceive(MessagingGatewaySupport.java:203) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.gateway.GatewayProxyFactoryBean.invokeGatewayMethod(GatewayProxyFactoryBean.java:306) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.gateway.GatewayProxyFactoryBean.doInvoke(GatewayProxyFactoryBean.java:269) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.integration.gateway.GatewayProxyFactoryBean.invoke(GatewayProxyFactoryBean.java:260) [spring-integration-core-2.2.3.RELEASE.jar:na]
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172) [spring-aop-3.2.2.RELEASE.jar:3.2.2.RELEASE]
at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:204) [spring-aop-3.2.2.RELEASE.jar:3.2.2.RELEASE]
at com.sun.proxy.$Proxy22.sendMessage(Unknown Source) [na:na]
at com.openshift.test.socket.SocketClient.sendMessage(SocketClient.java:24) [SocketClient.class:na]
at sun.reflect.GeneratedMethodAccessor21.invoke(Unknown Source) ~[na:na]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.7.0_19]
at java.lang.reflect.Method.invoke(Method.java:601) ~[na:1.7.0_19]
at org.springframework.scheduling.support.ScheduledMethodRunnable.run(ScheduledMethodRunnable.java:64) [spring-context-3.2.2.RELEASE.jar:3.2.2.RELEASE]
at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:53) [spring-context-3.2.2.RELEASE.jar:3.2.2.RELEASE]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) [na:1.7.0_19]
at java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:351) [na:1.7.0_19]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:178) [na:1.7.0_19]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178) [na:1.7.0_19]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [na:1.7.0_19]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) [na:1.7.0_19]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_19]
at java.lang.Thread.run(Thread.java:722) [na:1.7.0_19]
編集1
openshift は、発信接続でも内部 IP の使用のみを許可しているようです。spring-integration コードを調べましたが、クライアント接続用のローカル インターフェイスを設定する方法がありません。javax.net.SocketFactory
ターゲットホスト/ポートとローカルホストだけでソケットを取得する方法がないものがあっても。
したがって、今のところ問題は次のとおりです。
ソースとして特定のローカル IP を使用してリモート アドレスへのクライアント ソケットを開く方法