import java.io.Serializable;public class Packets implements Serializable{public int id;public String value;public int ballot_pid;public int ballot_num;public int position;public Packets(int id, String value, int ballot_pid, int ballot_num, int position){this.id= id;this.value= value;this.ballot_pid= ballot_pid;this.ballot_num= ballot_num;this.position= position;}
}

import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;public class Client{private int port= 2013;private String host= "127.0.0.1";public Client(String host, int port){this.host= host;this.port= port;}public void send(Packets packets) throws UnknownHostException, IOException{Socket socket= new Socket(host, port);ObjectOutputStream os= new ObjectOutputStream(socket.getOutputStream());os.writeObject(packets);socket.getOutputStream().flush();socket.close();}
}

import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;public class Server extends Thread{private int port= 2013;private int sequence= 1;/*flag used to stop this thread*/private boolean stop= false;/*pass addresses of clients from outside*/public Server(int port){this.port= port;}public void run(){Socket socket= null;try{ServerSocket serverSocket= new ServerSocket(port);while(!stop){socket= serverSocket.accept();handleSocket(socket);}}catch(Exception e){e.printStackTrace();}super.run();}private void handleSocket(Socket socket) throws IOException, ClassNotFoundException{ObjectInputStream ois= new ObjectInputStream(socket.getInputStream());Packets packets= (Packets)ois.readObject();/*handle packets start*//*if broadcast, use 'Blog.broadcast(Packets packets)'*/System.out.println("id : "+ packets.id);System.out.println("val: "+ packets.value);System.out.println("pid: "+ packets.ballot_pid);System.out.println("num: "+ packets.ballot_num);System.out.println("pos: "+ packets.position);    /*handle packets end*/socket.close();}/*function used to fail this server*/public void fail(){this.stop= true;}/*function used to restart this server*/public void unfail(){this.stop= false;}    }