java - Azure 和 Apache Mina

Question

我不确定这个问题是与 Mina 相关还是更多与 Azure 相关，但它与网络有关。我还添加了 Netty 标签，因为 Mina 和 Netty 共享许多网络原理。

我希望得到深入研究的建议。

我在本地网络中使用了某个 Mina 应用程序很长时间，现在我正在尝试将其迁移到云端。我在 Azure 中部署 Linux 虚拟机(每个虚拟机都有公共(public) IP，但这真的很重要吗？)。

他们(使用 Mina)连接到 Azure 之外的一台机器，该机器也有它的自己的公共(public)IP。平常的事情:

SocketConnector connector = new NioSocketConnector(numberOfConnectors);
ConnectFuture connectFuture = connector.connect(new
InetSocketAddress(remoteHost, remotePort));
connectFuture.awaitUninterruptibly(connectTimeout);

Azure 之外的那台 Mina 机器也运行 Mina。我们就这样调用它吧服务器机器。

它接受这样的连接:

NioSocketAcceptor acceptor = new NioSocketAcceptor(acceptor_threads);
org.apache.mina.core.buffer.IoBuffer.setUseDirectBuffer(false);
acceptor.getSessionConfig().setTcpNoDelay(true);
acceptor.setReuseAddress(true);
acceptor.getSessionConfig().setSendBufferSize(buffer_size);
acceptor.getSessionConfig().setMinReadBufferSize(64000);
acceptor.getSessionConfig().setReceiveBufferSize(buffer_size);
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, iddle_time);
acceptor.getFilterChain().addLast("codec", new
ProtocolCodecFilter(CodecFactory.getInstance()));
acceptor.setDefaultLocalAddress(new InetSocketAddress(port));

当 Azure 应用程序连接到服务器计算机时，服务器会保存

IoSession session

将来像这样异步推送消息:

session.write(message);

这在本地网络(没有 Azure)中运行良好，但在当前部署服务器发送消息

2017-01-17/15:45:19.823/GMT-00:00 [nioEventLoopGroup-3-3] [...] DEBUG
Sending message to /13.94.143.139:41790

并且 Azure 计算机不会收到任何内容。而且，经过一个而服务器端出现如下异常:

2017-01-17/16:01:11.419/GMT-00:00 [NioProcessor-4] [...] ERROR
Exception in IOHandlerConnection timed out
java.io.IOException: Connection timed out
    at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
    at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
    at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
    at sun.nio.ch.IOUtil.read(IOUtil.java:197)
    at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
    at org.apache.mina.transport.socket.nio.NioProcessor.read(NioProcessor.java:280)
    at org.apache.mina.transport.socket.nio.NioProcessor.read(NioProcessor.java:44)
    at org.apache.mina.core.polling.AbstractPollingIoProcessor.read(AbstractPollingIoProcessor.java:695)
    at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:668)
    at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:657)
    at org.apache.mina.core.polling.AbstractPollingIoProcessor.access$600(AbstractPollingIoProcessor.java:68)
    at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:1141)
    at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:64)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)

2017-01-17/16:01:11.424/GMT-00:00 [NioProcessor-3] [...] DEBUG sessionClosed

我使用 Mina 版本 2.0.4(是的，它很旧，但它现在可以在本地网络上运行好几年了)。

我使用 Java Azure SDK 1.0.0-beta3 设置 Azure 网络

Network.DefinitionStages.WithCreate creatableNetwork = azure.networks()
                    .define(networkName)
                    .withRegion(region)
                    .withExistingResourceGroup(resourceGroup)
                    .withAddressSpace("10.0.0.0/20");

并创建虚拟机

VirtualMachine.DefinitionStages.WithCreate creatableVirtualMachine =
         azure.virtualMachines()
           .define(String.format(...))
           .withRegion(region)
           .withExistingResourceGroup(resourceGroup)
           .withNewPrimaryNetwork(creatableNetwork)                             
           .withPrimaryPrivateIpAddressStatic(inetAddress.getHostAddress())
           .withNewPrimaryPublicIpAddress(String.format("chr-vm-%04d", i))                  .withPopularLinuxImage(KnownLinuxVirtualMachineImage.UBUNTU_SERVER_16_04_LTS)
           .withRootUserName(linuxUserName)
           .withPassword(linuxUserPassword)                                                                    
           .withSize(VirtualMachineSizeTypes.STANDARD_D2_V2)                                                 
           .withNewStorageAccount(creatableStorageAccount);

我想知道什么原因可能会阻止消息从服务器传输到Azure 客户端计算机？ Azure 网络配置？米娜配置？ (从客户端计算机到服务器计算机的第一条消息确实在连接后发出)

希望以上信息能给我们一些线索。

Answer 1

感谢 Peter Pan - MSFT 注意到 NSG - 网络安全组，我已经解决了我的问题。

NSG 像 Windows 防火墙一样控制输入/输出规则。您应该创建 NSG，向其添加规则，并将 NSG 分配给特定实体:

至少有两个分配 NSG 的选项:

• 到网络子网
• 连接到网络接口(interface)

有教程1和 Java 代码示例 2 。就我而言，为每个虚拟机创建一个单独的网络接口(interface)(因为每个虚拟机都有公共(public) IP)。因此，我将一个 NSG 分配给一个子网。

首先，创建 NSG:

NetworkSecurityGroup NSG = azure.networkSecurityGroups()
                    .define(networkSecurityGroup)
                    .withRegion(region)
                    .withExistingResourceGroup(resourceGroup)
                    .defineRule("Inbound")
                        .allowInbound()
                        .fromAnyAddress()
                        .fromAnyPort()
                        .toAnyAddress()
                        .toAnyPort()
                        .withAnyProtocol()
                        .withDescription("Incoming messsages")
                        .withPriority(100)
                        .attach()
                    .create();

然后修改代码以显式定义子网并向其分配 NSG(如果没有显式定义，则自动创建 subnet1 而不使用 NSG)

Network.DefinitionStages.WithCreate creatableNetwork = azure.networks()
                    .define(networkName)
                    .withRegion(region)
                    .withExistingResourceGroup(resourceGroup)
                    .withAddressSpace("10.0.0.0/20")
                    .defineSubnet(subnetName)
                        .withAddressPrefix("10.0.0.0/20")
                        .withExistingNetworkSecurityGroup(NSG)
                        .attach();

因此，其余代码与上面问题中发布的相同。

有用的链接:

1. Azure Portal Tutorial
2. Java Azure SDK NSG Example