testserver.java~2~

移动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
{
    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;
//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**************************************************************************************
}