frame1.java~32~

简单的TCP UDP通信源程序,已经在本机上实践通过.

package udp;

import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
//import java.net;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JRadioButton;
import java.awt.Rectangle;
import javax.swing.JLabel;
import javax.swing.JTextField;
import javax.swing.JButton;
import javax.swing.JTextArea;
import javax.swing.*;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2007</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class Frame1 extends JFrame {
    JPanel contentPane;
    JRadioButton jRadioButton1 = new JRadioButton();
    JRadioButton jRadioButton2 = new JRadioButton();
    JLabel jLabel1 = new JLabel();
    JTextField jTextField1 = new JTextField();
    JLabel jLabel2 = new JLabel();
    JTextField jTextField2 = new JTextField();
    JButton jButton1 = new JButton();
    JButton jButton2 = new JButton();
    JButton jButton3 = new JButton();
    JLabel jLabel3 = new JLabel();
    JTextArea jTextArea1 = new JTextArea();
    JLabel jLabel4 = new JLabel();
    JTextField jTextField3 = new JTextField();
    JLabel jLabel5 = new JLabel();
    DatagramSocket socket1;
    String strbuf;
    udpserver t1;
    udpclient t2;
    public Frame1() {
        try {
            setDefaultCloseOperation(EXIT_ON_CLOSE);
            jbInit();
        } catch (Exception exception) {
            exception.printStackTrace();
        }
    }

    /**
     * Component initialization.
     *
     * @throws java.lang.Exception
     */
    private void jbInit() throws Exception {
        contentPane = (JPanel) getContentPane();
        contentPane.setLayout(null);
        setSize(new Dimension(526, 437));
        setTitle("Frame Title");
        jRadioButton1.setText("服务器端");
        jRadioButton1.setBounds(new Rectangle(11, 28, 94, 23));
        jRadioButton2.setText("客户端");
        jRadioButton2.setBounds(new Rectangle(121, 29, 78, 23));
        jLabel1.setText("连接状态");
        jLabel1.setBounds(new Rectangle(257, 31, 56, 22));
        jTextField1.setHorizontalAlignment(SwingConstants.RIGHT);
        jTextField1.setBounds(new Rectangle(314, 33, 185, 20));
        jLabel2.setText("连接主机名称");
        jLabel2.setBounds(new Rectangle(10, 68, 76, 26));
        jTextField2.setBounds(new Rectangle(91, 73, 312, 20));
        jButton1.setBounds(new Rectangle(419, 71, 81, 23));
        jButton1.setText("连接");
        jButton1.addActionListener(new Frame1_jButton1_actionAdapter(this));
        //jButton1.addActionListener(this);
        jButton2.setBounds(new Rectangle(421, 111, 81, 23));
        jButton2.setText("结束连接");
        jButton2.addActionListener(new Frame1_jButton2_actionAdapter(this));
        jButton3.setBounds(new Rectangle(419, 351, 81, 23));
        jButton3.setText("发送信息");
        jButton3.addActionListener(new Frame1_jButton3_actionAdapter(this));
        jLabel3.setText("接收的信息");
        jLabel3.setBounds(new Rectangle(12, 112, 70, 25));
        jTextArea1.setBounds(new Rectangle(92, 111, 309, 211));
        jLabel4.setText("发送信息");
        jLabel4.setBounds(new Rectangle(11, 348, 65, 23));
        jTextField3.setBounds(new Rectangle(92, 347, 312, 26));
        jLabel5.setText("UDP通信程序");
        jLabel5.setBounds(new Rectangle(16, 8, 128, 15));
        contentPane.add(jTextField2);
        contentPane.add(jButton2);
        contentPane.add(jTextArea1);
        contentPane.add(jLabel3);
        contentPane.add(jLabel2);
        contentPane.add(jTextField3);
        contentPane.add(jButton3);
        contentPane.add(jLabel4);
        contentPane.add(jButton1);
        contentPane.add(jRadioButton1, null);
        contentPane.add(jRadioButton2);
        contentPane.add(jLabel1);
        contentPane.add(jTextField1);
        contentPane.add(jLabel5);
         t1=new udpserver();
         t2=new udpclient();
    }

    class udpserver extends Thread{
        public udpserver(){}
        public void run(){
            String str1;
            try{jButton1.setEnabled(false);
                socket1=new DatagramSocket(911);
                jTextField2.setText(InetAddress.getLocalHost().getHostName());
                jTextField1.setText("连接中!");
                jButton2.setEnabled(true);
                jButton3.setEnabled(true);
                while(true)
                    //接收
                {byte[] inbuffer=new byte[256];
                  DatagramPacket packet1=new DatagramPacket(inbuffer,inbuffer.length);
                  socket1.receive(packet1);
                  str1=new String(packet1.getData());
                  str1=str1.trim();
                  if(str1.length()>0){jTextArea1.setText(str1+"\n");}
                 //发送
                 str1=strbuf;
                 byte[] outbuffer=new byte[str1.length()];
                 strbuf="";
                 outbuffer=str1.getBytes();
                 InetAddress address=packet1.getAddress();
                 int port=packet1.getPort();
                 packet1=new DatagramPacket(outbuffer,outbuffer.length,address,port);
                 socket1.send(packet1);
                }
            }
            catch(IOException e){return;}
        }
    }
    class udpclient extends Thread{
       public udpclient(){}
       public void run(){
           String str1;
           DatagramPacket packet1;
           try{jButton1.setEnabled(false);
               socket1=new DatagramSocket();
               jTextField2.setText(InetAddress.getLocalHost().getHostName());
               jTextField1.setText("连接中!");
               jButton2.setEnabled(true);
               jButton3.setEnabled(true);
              // int i=0;
               while(true)
                   //发送
                   {
                       //jTextField3.setText("123"+i+strbuf);
                       str1=strbuf;
                    byte[] outbuffer=new byte[str1.length()];
                    strbuf="";
                    outbuffer=str1.getBytes();
                    InetAddress address=InetAddress.getByName(jTextField2.getText());
                    packet1=new DatagramPacket(outbuffer,outbuffer.length,address,911);
                    socket1.send(packet1);
                    //接收
                    byte[] inbuffer=new byte[256];
                   packet1=new DatagramPacket(inbuffer,inbuffer.length);
                  socket1.receive(packet1);
                  str1=new String(packet1.getData());
                  str1=str1.trim();
                  if(str1.length()>0){jTextArea1.append(str1+"\n");}
               }
           }
           catch(IOException e){}
       }
   }

    public void jButton1_actionPerformed(ActionEvent e) {
        try{if(jRadioButton1.isSelected()==true){
                           jTextField2.setText("");
                           t1.start();
                       } else {
                           jTextField2.setText("");
                           t2.start();
                       }
                   }
                   catch(Exception e2){jTextField1.setText("发生错误");
                       }
    }

    public void jButton2_actionPerformed(ActionEvent e) {
        try{//关闭连接
                        if(jRadioButton1.isSelected()==true){
                        socket1.close();
                        t1.interrupt();
                        } else {
                            t2.interrupt();
                        }
                       jTextField1.setText("离线!");
                       jButton2.setEnabled(false);
                       jButton3.setEnabled(false);
                    }
                    catch(Exception e2){jTextField1.setText("发生错误");
                        }
         }

    public void jButton3_actionPerformed(ActionEvent e) {
           strbuf=jTextField3.getText();
          jTextField3.setText("");
    }
}


class Frame1_jButton3_actionAdapter implements ActionListener {
    private Frame1 adaptee;
    Frame1_jButton3_actionAdapter(Frame1 adaptee) {
        this.adaptee = adaptee;
    }

    public void actionPerformed(ActionEvent e) {
        adaptee.jButton3_actionPerformed(e);
    }
}


class Frame1_jButton2_actionAdapter implements ActionListener {
    private Frame1 adaptee;
    Frame1_jButton2_actionAdapter(Frame1 adaptee) {
        this.adaptee = adaptee;
    }

    public void actionPerformed(ActionEvent e) {
        adaptee.jButton2_actionPerformed(e);
    }
}


class Frame1_jButton1_actionAdapter implements ActionListener {
    private Frame1 adaptee;
    Frame1_jButton1_actionAdapter(Frame1 adaptee) {
        this.adaptee = adaptee;
    }

    public void actionPerformed(ActionEvent e) {
        adaptee.jButton1_actionPerformed(e);
    }
}