SNMP4J サーバー接続タイムアウト問題の解決策

	/**
	 * 指定されたアドレスに SNMP メッセージを送信します。
	 * 
	 * @param アドレス
	 * <code>TcpAddress</code>。
	 * <code>ClassCastException</code> がスローされます。
	 * <code>address</code> は <code>TcpAddress</code> ではありません
	 * 実例。
	 * @param メッセージ
	 * byte[] 送信するメッセージ。
	 * @throwsIOException 例外をスローします
	 */
	public void sendMessage(Address アドレス、byte[] メッセージ)
			java.io.IOException をスローします {
		if (サーバー == null) {
			聞く（）;
		}
		serverThread.sendMessage(アドレス、メッセージ);
	}

	public void sendMessage(Address アドレス、byte[] メッセージ)
			java.io.IOException をスローします {
		ソケット s = null;
		SocketEntry エントリ = (SocketEntry) sockets.get(address);
		ロガーがデバッグ有効の場合
			logger.debug("宛先への接続を検索しています '"
					+ アドレス + "' が返されました: " + エントリ);
			ロガー.デバッグ(sockets.toString());
		}
		if (エントリ != null) {
			s = エントリ.getSocket();
		}
		s == null の場合 || (s.isClosed()) || (!s.isConnected())) {
			ロガーがデバッグ有効の場合
				logger.debug("アドレス ' のソケット" + アドレス
						+ "' は閉じられており、開くと...");
			}
			保留中。削除(エントリ);
			ソケットチャネル sc = null;
			試す {
				// チャネルを開き、非ブロッキングに設定し、開始します
				// 接続する
				sc = SocketChannel.open();
				sc.configureBlocking(false);
				scで
						.connect(新しいInetSocketAddress(
								((TcpAddress) アドレス).getInetAddress(),
								((TcpAddress) アドレス).getPort()));
				s = sc.socket();
				エントリ = 新しい SocketEntry((TcpAddress) アドレス、s);
				エントリ.addMessage(メッセージ);
				sockets.put(アドレス、エントリ);
	
				同期済み（保留中）{
					保留中。追加(エントリ);
				}
	
				セレクター.wakeup();
				logger.debug("" + アドレスに接続しようとしています);
			} キャッチ (IOException iox) {
				ロガーエラー(iox);
				iox を投げる;
			}
		} それ以外 {
			エントリ.addMessage(メッセージ);
			同期済み（保留中）{
				保留中。追加(エントリ);
			}
			セレクター.wakeup();
		}
	}

プライベート同期void timeoutSocket(SocketEntryエントリ) { 
  接続タイムアウト > 0 の場合 
    socketCleaner.schedule(新しいSocketTimeout(entry)、connectionTimeout); 
  } 
}

プライベートvoid init()はUnknownHostException、IOExceptionをスローします{ 
  スレッドプール = ThreadPool.create("トラップ", 2); 
  ディスパッチャー = 新しい MultiThreadedMessageDispatcher(threadPool、新しい MessageDispatcherImpl()); 
  // ローカル IP とリスニング ポート listenAddress = GenericAddress.parse(System.getProperty("snmp4j.listenAddress", "tcp:192.168.9.69/5055")); 
  DefaultTcpTransportMapping トランスポート; 
  トランスポート = 新しい DefaultTcpTransportMapping((TcpAddress) listenAddress); 
  トランスポート.setConnectionTimeout(0); 
  snmp = 新しい Snmp(ディスパッチャ、トランスポート); 
  snmp.getMessageDispatcher().addMessageProcessingModel(新しいMPv1()); 
  snmp.getMessageDispatcher().addMessageProcessingModel(新しい MPv2c()); 
  snmp.getMessageDispatcher().addMessageProcessingModel(新しいMPv3()); 
  USM usm = 新しい USM(SecurityProtocols.getInstance()、新しい OctetString(MPv3.createLocalEngineID())、0); 
  セキュリティモデルを取得します。セキュリティモデルを追加します(usm); 
  snmp.listen(); 
}