JAVA UDP传输数据

JasonShieh

浏览: 528577 次
性别:
来自: 上海

最近访客更多访客>>

ming1279

pcpig

xiaohou12345

zhengjiong

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

Java thread Swing .net

import java.net.*;
import javax.swing.*;
import java.awt.event.*;
class 主机1Frame extends JFrame implements Runnable,ActionListener
{ JTextField out_message=new JTextField("发送数据到主机2：");
   JTextArea in_message=new JTextArea();
   JButton b=new JButton("发送数据包到主机2");
   主机1Frame()
   { super("我是主机1");
      setSize(200,200);setVisible(true);
      b.addActionListener(this);
      add(out_message,"South");add(in_message,"Center");add(b,"North");
      Thread thread=new Thread(this);
      thread.start();//线程负责接收数据包
   }
   public void actionPerformed(ActionEvent event) //点击按扭发送数据包
   { byte buffer[]=out_message.getText().trim().getBytes();
      try{ InetAddress address=InetAddress.getByName("127.0.0.1");
DatagramPacket data_pack=
new DatagramPacket(buffer,buffer.length, address,888);
            DatagramSocket mail_data=new DatagramSocket();
            in_message.append("数据报目标主机地址:"+data_pack.getAddress()+"\n");
            in_message.append("数据报目标端口是:"+data_pack.getPort()+"\n");
            in_message.append("数据报长度:"+data_pack.getLength()+"\n");
            mail_data.send(data_pack);
          }
      catch(Exception e){}
   }
   public void run() //接收数据包
   { DatagramPacket pack=null;
      DatagramSocket mail_data=null;
      byte data[]=new byte[8192];
      try{ pack=new DatagramPacket(data,data.length);
            mail_data=new DatagramSocket(666);
         }
      catch(Exception e){}
      while(true)
         { if(mail_data==null) break;
            else
               try{ mail_data.receive(pack);
                     int length=pack.getLength();
                     InetAddress adress=pack.getAddress();
                     int port=pack.getPort();
                     String message=new String(pack.getData(),0,length);
                     in_message.append("收到数据长度："+length+"\n");
                     in_message.append("收到数据来自："+adress+"端口："+port+"\n");
                     in_message.append("收到数据是："+message+"\n");
                  }
               catch(Exception e){}
         }
   }
}
public class 主机1
{ public static void main(String args[])
   { 主机1Frame 主机1win=new 主机1Frame();
      主机1win.validate();
   }
}

Java codeimport java.net.*;
import javax.swing.*;
import java.awt.event.*;
class 主机2Frame extends JFrame implements Runnable,ActionListener
{ JTextField out_message=new JTextField("发送数据到主机1：");
   JTextArea in_message=new JTextArea();
   JButton b=new JButton("发送数据包到主机1");
   主机2Frame()
   { super("我是主机2");
      setSize(200,200);setVisible(true);
      b.addActionListener(this);
      add(out_message,"South");add(in_message,"Center");add(b,"North");
      Thread thread=new Thread(this);
      thread.start();//线程负责接收数据包
   }
   public void actionPerformed(ActionEvent event)
   { byte buffer[]=out_message.getText().trim().getBytes();
      try{ InetAddress address=InetAddress.getByName("127.0.0.1");
DatagramPacket data_pack=
new DatagramPacket(buffer,buffer.length, address,666);
            DatagramSocket mail_data=new DatagramSocket();
            in_message.append("数据报目标主机地址:"+data_pack.getAddress()+"\n");
            in_message.append("数据报目标端口是:"+data_pack.getPort()+"\n");
            in_message.append("数据报长度:"+data_pack.getLength()+"\n");
            mail_data.send(data_pack);
         }
       catch(Exception e){}
   }
   public void run()
   { DatagramSocket mail_data=null;
      byte data[]=new byte[8192];
      DatagramPacket pack=null;
     try{
           pack=new DatagramPacket(data,data.length);
           mail_data=new DatagramSocket(888);
         }
     catch(Exception e){}
     while(true)
       { if(mail_data==null) break;
          else
           try{ mail_data.receive(pack);
                 int length=pack.getLength();
                InetAddress adress=pack.getAddress();
                int port=pack.getPort();
   String message=new String(pack.getData(),0,length);
                in_message.append("收到数据长度："+length+"\n");
                in_message.append("收到数据来自："+adress+"端口："+port+"\n");
                in_message.append("收到数据是："+message+"\n");
              }
           catch(Exception e){}
       }
   }
}
public class 主机2
{   public static void main(String args[])
   { 主机2Frame 主机2win=new 主机2Frame();
       主机2win.validate();
   }
}

分享到：