服務器：

import java.io.IOException;
import java.net.ServerSocket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadServer {

    public static void main(String[] args) {
        try {
            ServerSocket server = new ServerSocket(20011);
            ExecutorService executor=Executors.newFixedThreadPool(20);
            // 構造一個線程池
            //ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 4, 3, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(3),
                 //   new ThreadPoolExecutor.DiscardOldestPolicy());
            boolean flag = true;
            while (flag) {
                System.out.println("準備接入客戶端");
                executor.execute(new Handler(server.accept())); 
                System.out.println("客戶端已經連接");
            }
            server.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    
    
}
    


import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Arrays;


public class Handler extends Thread {

    private Socket client = null;
    private BufferedReader input = null;
    private OutputStream out = null;
    //獲取Socket的輸入流，用來接收從服務端發(fā)送過來的數據 
    InputStream buf =  null;  
    
    public Handler(Socket client ) {
        this.client = client;
        try {
            input = new BufferedReader(new InputStreamReader(client.getInputStream()));
            out = client.getOutputStream();
            buf = client.getInputStream();
            start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    @Override
    public void run() {
        try {
            try {
                byte[] b = new byte[1024];
                int rc=0;
                int c = 0;
                rc = buf.read(b, c, 1024);
                byte[] byte8583 = Arrays.copyOfRange(b, 0, rc);
                System.out.println("post:"+byteToHexString(byte8583));
                byte[] result = send8583(byte8583, "139.129.223.93", 8500);
                System.out.println("return:"+byteToHexString(result));
                out.write(result,0,result.length);
                out.flush();
            }catch (IOException e)  {
                String error = "IOException";
                System.out.println(error);
            }catch (IllegalArgumentException e) {
            } finally{
                out.close();
                input.close();
                client.close();
            }
        } catch (IOException e) {
            System.out.println("發(fā)生了IOException");
        }
    }
    
}

客戶端：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.net.SocketTimeoutException;

public class Client {

    public static void main(String[] args) throws IOException {
        Socket client = new Socket("127.0.0.1", 20011);  
        //客戶端請求與本機在20011端口建立TCP連接 
        client.setSoTimeout(10000);             
        BufferedReader input = new BufferedReader(new InputStreamReader(System.in)); 
        //獲取鍵盤輸入        
        PrintStream out = new PrintStream(client.getOutputStream());          
        //獲取Socket的輸出流，用來發(fā)送數據到服務端                  
        BufferedReader buf =  new BufferedReader(new InputStreamReader(client.getInputStream()));  
        //獲取Socket的輸入流，用來接收從服務端發(fā)送過來的數據 
        boolean flag = true;  
        while(flag){  
            System.out.print("輸入信息：");  
            String str = input.readLine();  
            out.println(str);  
            //發(fā)送數據到服務端   
            if("end".equals(str)){  
                flag = false;  
            }else{  
                try{  
                    String echo = buf.readLine();  
                    System.out.println(echo);  
                }catch(SocketTimeoutException e){  
                    System.out.println("Time out, No response");  
                }  
            }  
        }  
        input.close();  
        if(client != null){  
            //如果構造函數建立起了連接，則關閉套接字，如果沒有建立起連接，自然不用關閉  
            System.out.println("客戶端關閉");
            client.close(); //只關閉socket，其關聯(lián)的輸入輸出流也會被關閉  
        } 
    }
    
    
}