Java Socket Demo

服务端：

package com.sux.demo;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.List;

public class TestServerSocket {
    public static void main(String[] args) throws IOException, ClassNotFoundException, InterruptedException {
        ReceiveThread receiveThread = new ReceiveThread();
        receiveThread.start();
    }


}

class ReceiveThread extends Thread {

    public void run() {
        try {
            ServerSocket serverSocket = new ServerSocket(8888);
            while (true) {
                Socket socket = serverSocket.accept();
                receive(socket);
                socket.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void receive(Socket socket) throws IOException, ClassNotFoundException, InterruptedException {
        InputStream inputStream = socket.getInputStream();
        DataInputStream dataInputStream = new DataInputStream(inputStream);
        BufferedInputStream bufferedInputStream = new BufferedInputStream(dataInputStream);
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();

        int len;
        byte[] bytes = new byte[10240];
        while ((len = bufferedInputStream.read(bytes)) > 0) {
            byteArrayOutputStream.write(bytes, 0, len);
        }

        System.out.println("Server端接收的数据：");
        List<MyInfo> list = (List<MyInfo>) SerializeUtil.Deserialize(byteArrayOutputStream.toByteArray());
        for (MyInfo myInfo : list) {
            System.out.println(myInfo.toString());
        }
    }
}

View Code