用SNMP协议监测TCP连接.doc

通过编程和服务器建立一条TCP连接，然后利用SNMP协议监测主机上的这条TCP连接，获取监测的信息（本地地址、端口及服务器的地址、端口以及连接的状态），将获取监测的信息连同学号发送给服务器。完整代码如下：import java.io.*;import .Socket;import java.util.List;import org.snmp4j.CommunityTarget;import org.snmp4j.PDU;import org.snmp4j.Snmp;import org.snmp4j.TransportMapping;import org.snmp4j.mp.SnmpConstants;import org.snmp4j.smi.Address;import org.snmp4j.smi.GenericAddress;import org.snmp4j.smi.OID;import org.snmp4j.smi.OctetString;import org.snmp4j.smi.VariableBinding;import org.snmp4j.transport.DefaultUdpTransportMapping;import org.snmp4j.util.DefaultPDUFactory;import org.snmp4j.util.TableEvent;import org.snmp4j.util.TableUtils;public class TestNetStat public static void main(String args) throws IOExceptionString outinfo;Socket socket=new Socket(4, 27);try TcpUtil myutil = new TcpUtil();outinfo=myutil.printTcpConn();System.out.println(socket=+socket);BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream();PrintWriter out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),true);if(outinfo!=null) out.println(outinfo+M20);System.out.println(发送的信息：);System.out.println(outinfo+M20);System.out.println(接收的信息：);String str=in.readLine();System.out.println(str);in.close();out.close();System.out.println(发送监听成功！1);socket.close();catch(IOException e)e.printStackTrace();class NetStatstatic String stat=?,CLOSED,LISTENING,SYN_SENT,SEN_RECEIVED,ESTABLISHED,FIN_WAIT,FIN_WAIT2,CLOSE_WAIT,CLOSING,LAST_ACK,TIME_WAIT;class TcpUtilpublic String printTcpConn() throws IOExceptionString str = null;TransportMapping transport = new DefaultUdpTransportMapping();Snmp snmp = new Snmp(transport);transport.listen(); Address targetAddress = GenericAddress.parse(udp:/161); CommunityTarget target = new CommunityTarget();target.setCommunity(new OctetString(public);target.setAddress(targetAddress);target.setRetries(2);target.setTimeout(1500);target.setVersion(SnmpConstants.version2c); TableUtils tutils = new TableUtils(snmp, new DefaultPDUFactory(PDU.GETBULK);/GETNEXT or GETBULK tutils.setMaxNumRowsPerPDU(5); OID columnOID=new OID5;columnOID0=new OID(.3.1.1);columnOID1=new OID(.3.1.2);columnOID2=new OID(.3.1.3);columnOID3=new OID(.3.1.4);columnOID4=new OID(.3.1.5); List tabEveList=tutils.getTable(target, columnOID, null, null); int tabEveNum=tabEveList.size();System.out.println(地址转发表数目：+tabEveNum); System.out.print(StatettLocalAddresstLocalPorttRemAddresstRemPortn); for(int i=0;itabEveNum;i+)TableEvent tabEve=tabEveList.get(i);VariableBinding varBindings=tabEve.getColumns();int s=(int)varBindings0.getVariable().toInt();System.out.print(NetStat.stats+t);System.out.print(varBindings1.getVariable()+t);System.out.print(varBindings2.getVariable()+t);if(varBindings3.getVariable().toString().equals(4)str=varBindings1.getVariable().toString()+t;str+=varBindings2.getVariable().toString()+t;str+=varBindings3.getVariable().toString()+t;str+=varBindin