testserver.java~4~

移动CMPP3.0协议短信网关连接程序

import java.awt.*;
import javax.swing.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
public class testserver extends JFrame implements ActionListener
{
    public static void main(String[] args)
  {
     testserver frame=new testserver();
  }

    JButton command, command2, command3;
    JRadioButton rb[] = new JRadioButton[2];
    JTextArea tal;
    JTextField tf1, tf2, tf3;
    ServerSocket socket1;
    Socket insocket1, socket2;
    String inbuf;
    BufferedReader in1;
    PrintWriter out1;
    ml625_server t1;
    ml625_client t2;
    public testserver()
{
        super("testserver");
}
    public void actionPerformed(ActionEvent e)
{
 if(e.getSource()==command)
    {
     try{
         if(rb[0].isSelected()==true)
            {
             inbuf="";
             tf2.setText("");
             //启动server线程
             t1.start();
            }
          else
            {
             inbuf="";
             tf2.setText("");
             //启动client线程
             t2.start();
            }
         }
      catch(Exception e2)
         {
//            tf3.setText("发生错误");
         }
    }
 if(e.getSource()==command2)
    {
     //发送信息
     out1.write(tf2.getText()+"\n");
     out1.flush();
     tf2.setText("");
    }
 if(e.getSource()==command3)
    {
     try{
         if(rb[0].isSelected()==true)
            {
             //关闭server端socket
             insocket1.close();
//               tf3.setText("离线！");
             command2.setEnabled(false);
             command3.setEnabled(false);
             }
           else
             {
              //关闭client端socket
              socket2.close();
//               tf3.setText("离线！");
              command2.setEnabled(false);
              command3.setEnabled(false);
             }
        }
      catch(Exception e2)
        {
//           tf3.setText("发生错误");
        }
    }
}

//ml625_server_1**************************************************************************************************
    class ml625_server extends Thread {
        public ml625_server() {}

        public void run() {
            try {
                command.setEnabled(false);
//         tf3.setText("正在等待连接！");
                tf1.setText(InetAddress.getLocalHost().getHostAddress());
                socket1 = new ServerSocket(4500);
                insocket1 = socket1.accept();
                in1 = new BufferedReader(new InputStreamReader(insocket1.
                        getInputStream()));
                out1 = new PrintWriter(insocket1.getOutputStream(), true);

                while (true) {
                    if (socket1.isBound() == true) {
//             tf3.setText("正在连接！");
                        command2.setEnabled(true);
                        command3.setEnabled(true);
                        break;
                    }
                } while (true) {
                    inbuf = in1.readLine();
                    if (inbuf.length() > 0) {
                        tal.append(inbuf);
                        tal.append("\n");
                    }
                }
            } catch (Exception e) {}
        }
    }
//ml625_server_2**************************************************************************************************
//ml625_client_1**************************************************************************************
    class ml625_client extends Thread
{
public ml625_client(){}
public void run()
  {
   try
     {
      command.setEnabled(false);
//        tf3.setText("正在等待连接！");
      socket2=new Socket();
      socket2.connect(new InetSocketAddress(tf1.getText(),4500),5000);
      in1=new BufferedReader (new InputStreamReader(socket2.getInputStream()));
      out1=new PrintWriter (socket2.getOutputStream(),true);
      while(true)
        {
         if(socket2.isConnected()==true)
           {
//              tf3.setText("正在连接！");
            command2.setEnabled(true);
            command3.setEnabled(true);
            tf2.setText("1234");
            break;
           }
        }
       inbuf="";
       while(true)
         {
          inbuf=in1.readLine();
          if(inbuf.length()>0)
            {
             tal.append(inbuf);
             tal.append("\n");
            }
         }
       }
     catch (Exception e) {}
  }
}
//ml625_client_2**************************************************************************************
}