package heart;import java.io.Serializable;public class Entity implements Serializable {private static final long serialVersionUID = 1L;private String name;private String sex;public String getName() {return name;}public void setName(String name) {this.name = name;}public String getSex() {return sex;}public void setSex(String sex) {this.sex = sex;}@Overridepublic String toString() {return "Entity [name=" + name + ", sex=" + sex + "]";}}

package heart;public class ClientHeart extends Thread {@Overridepublic void run() {try {while (true) {ClientSender.getInstance().send();synchronized (ClientHeart.class) {// this.wait(5000);Thread.sleep(2000);}}} catch (Exception e) {e.printStackTrace();}}/*** 程序的入口main方法* * @param args*/public static void main(String[] args) {ClientHeart client = new ClientHeart();client.start();}}

package heart;import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.Socket;import echoserver.EchoServer;
import heart.Entity;public class ClientSender {private ClientSender() {}Socket sender = null;private static ClientSender instance;public static ClientSender getInstance() {if (instance == null) {synchronized (ClientHeart.class) {instance = new ClientSender();}}return instance;}@SuppressWarnings("static-access")public void send() {try {sender = new Socket("192.168.1.166", 9090);while (true) {ObjectOutputStream out = new ObjectOutputStream(sender.getOutputStream());Entity obj = new Entity();obj.setName("xiaoming");obj.setSex("男");out.writeObject(obj);out.flush();System.out.println("已发送...");Thread.sleep(5000);}} catch (Exception e) {EchoServer myServer = new EchoServer();System.out.println("连接异常");try {myServer.main(null);} catch (Exception e1) {// TODO Auto-generated catch block
                e1.printStackTrace();}}}
}

package heart;import java.io.ObjectInput;
import java.io.ObjectInputStream;
import java.net.ServerSocket;
import java.net.Socket;
import heart.Entity;public class ServerHeart extends Thread {private ServerSocket server = null;Object obj = new Object();@Overridepublic void run() {try {server = new ServerSocket(9090);while (true) {Socket client = server.accept();synchronized (obj) {new Thread(new Client(client)).start();}}} catch (Exception e) {e.printStackTrace();}}/*** 客户端线程* * @author USER**/class Client implements Runnable {Socket client;public Client(Socket client) {this.client = client;}@Overridepublic void run() {try {while (true) {ObjectInput in = new ObjectInputStream(client.getInputStream());Entity entity = (Entity) in.readObject();System.out.println(entity);}} catch (Exception e) {e.printStackTrace();}}}/*** 程序的入口main方法* * @param args*/public static void main(String[] args) {System.out.println("开始检测服务器是否done机...");new ServerHeart().start();}
}