У меня есть приложение SNMP-ловушек в Java, которое нацелено на прослушивание агента SNMP и печать полученных сообщений SNMP на JTextArea в окне JFrame.
Часть I ниже - это мой исходный код, показывающий содержимое класса TrapReceiver. В этом классе метод listen - это место, которое делает большую часть работы. Класс создан внутри класса JFrame, на котором я собираюсь показывать сообщения в упомянутой выше JTeaxtArea. Я отправляю ссылку на объект JTextArea, URL-адрес агента SNMP и порт в конструктор класса TrapReceiver, а затем вызываю метод run объекта TrapReceiver, чтобы запустить выполнение в отдельном потоке, отличном от экземпляра JFrame. Часть II ниже показывает, как я создаю экземпляр класса TrapReeceiver в экземпляре JFrame.
Когда я запустил приложение, я заметил, что экземпляр JFrame (то есть GUI) зависает, и на упомянутом JTeaxtArea внутри экземпляра JFrame не печатается сообщение, которое создает экземпляр класса TrapReeceiver, показанного в части I ниже.
Мой вопрос заключается в том, почему экземпляр JFrame (то есть GUI) зависает, хотя сам TRapReceiver выполняется как отдельный поток? Кроме того, мне интересно, что может быть возможным решением этой проблемы замораживания. Заранее спасибо.
P.S .: Я проверил, что TrapReceiver работает нормально и может печатать сообщения на стандартный вывод при запуске в качестве автономного приложения без графического интерфейса, но именно этот графический интерфейс каким-то образом зависает из-за некоторой возможной проблемы синхронизации потоков. Я пытался запустить TrapReceiver, не добавляя его в поток, и даже в этом случае графический интерфейс по-прежнему зависал.
ЧАСТЬ I
package com.[Intenionally removed].snmp;
import java.io.IOException;
import javax.swing.JTextArea;
import org.snmp4j.*;
import org.snmp4j.mp.MPv1;
import org.snmp4j.mp.MPv2c;
import org.snmp4j.security.Priv3DES;
import org.snmp4j.security.SecurityProtocols;
import org.snmp4j.smi.OctetString;
import org.snmp4j.smi.TcpAddress;
import org.snmp4j.smi.TransportIpAddress;
import org.snmp4j.smi.UdpAddress;
import org.snmp4j.transport.AbstractTransportMapping;
import org.snmp4j.transport.DefaultTcpTransportMapping;
import org.snmp4j.transport.DefaultUdpTransportMapping;
import org.snmp4j.util.MultiThreadedMessageDispatcher;
import org.snmp4j.util.ThreadPool;
public class TrapReceiver implements CommandResponder, Runnable {
private String targetSnmpAgentURL;
private int targetSnmpAgentPort;
private JTextArea outConsole;
public TrapReceiver() {
}
public TrapReceiver(JTextArea outConsole) {
this.outConsole = outConsole;
}
public TrapReceiver(JTextArea outConsole, String targetSnmpAgentURL, int targetSnmpAgentPort) {
this.targetSnmpAgentURL = targetSnmpAgentURL;
this.targetSnmpAgentPort = targetSnmpAgentPort;
this.outConsole = outConsole;
try {
listen(new UdpAddress(targetSnmpAgentURL + "/" + targetSnmpAgentPort));
} catch (IOException e) {
e.printStackTrace();
}
}
public final synchronized void listen(TransportIpAddress address) throws IOException {
AbstractTransportMapping transport;
if (address instanceof TcpAddress) {
transport = new DefaultTcpTransportMapping((TcpAddress) address);
} else {
transport = new DefaultUdpTransportMapping((UdpAddress) address);
}
ThreadPool threadPool = ThreadPool.create("DispatcherPool", 10);
MessageDispatcher mDispathcher = new MultiThreadedMessageDispatcher(
threadPool, new MessageDispatcherImpl());
// add message processing models
mDispathcher.addMessageProcessingModel(new MPv1());
mDispathcher.addMessageProcessingModel(new MPv2c());
// add all security protocols
SecurityProtocols.getInstance().addDefaultProtocols();
SecurityProtocols.getInstance().addPrivacyProtocol(new Priv3DES());
// Create Target
CommunityTarget target = new CommunityTarget();
target.setCommunity(new OctetString("public"));
Snmp snmp = new Snmp(mDispathcher, transport);
snmp.addCommandResponder(this);
transport.listen();
System.out.println("Listening on " + address);
try {
this.wait();
} catch (InterruptedException ex) {
Thread.currentThread().interrupt();
}
}
/**
* This method will be called whenever a pdu is received on the given port
* specified in the listen() method
*/
@Override
public synchronized void processPdu(CommandResponderEvent cmdRespEvent) {
//System.out.println("Received PDU...");
outConsole.append("Received PDU...\n");
PDU pdu = cmdRespEvent.getPDU();
if (pdu != null) {
outConsole.append("Trap Type = " + pdu.getType() + "\n");
outConsole.append("Alarm Type: " + pdu.getVariableBindings().get(4) + "\n");
outConsole.append("Alarm Message: " + pdu.getVariableBindings().get(9) + "\n\n");
}
}
@Override
public void run() {
try {
listen(new UdpAddress(targetSnmpAgentURL + "/" + targetSnmpAgentPort));
} catch (IOException e) {
outConsole.append("\nError occured while listening to SNMP messages: \n" + e.getMessage() + "\n\n");
}
}
} //end of class TrapReceiver
ЧАСТЬ II
Далее я запускаю экземпляр класса TrapReceiver в потоке.
private void jButtonStartListeningSNMPActionPerformed(java.awt.event.ActionEvent evt) {
Thread snmpThread =
new Thread(new TrapReceiver(jTextAreaSNMPAlarmOutput, jTextFieldSnmpAgentUrl.getText().trim(), Integer.parseInt(jTextFieldSnmpAgentPort.getText().trim())));
snmpThread.start()
}