package com.server;

import java.io.IOException;

import java.io.ObjectInputStream;

import java.io.ObjectOutputStream;

import java.net.ServerSocket;

import java.net.Socket;

import com.jim.Student;

public class QQServer {

    /**

     * @param args

     */

    public static void main(String[] args) {

        // TODO Auto-generated method stub

        System.out.println("Start Server...");

        QQServer server = new QQServer();

    }

    //构造函数

    public QQServer()

    {

         Socket s;

        //创建ServerSocket在9999号端口监听

         ServerSocket ss = null;

         try {

            ss = new ServerSocket(9999);

        } catch (IOException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

        System.out.println("服务器正在监听........");

            try {

                System.out.println("开始等待连接...");

                s = ss.accept();//阻塞，等待连接

                System.out.println("客户端连接成功");

                //接收流

                ObjectInputStream ois=new ObjectInputStream(s.getInputStream());

                //发送流

                ObjectOutputStream oos = new ObjectOutputStream(

                        s.getOutputStream());

                //接收Student对象

                Student stu = (Student) ois.readObject();

                System.out.println(stu.getName());

                //发送Student对象

                oos.writeObject(new Student("Server"));

            } catch (Exception e) {

                // TODO Auto-generated catch block

                e.printStackTrace();

            }

        }

}

package com.client;

import java.io.*;

import java.net.*;

import com.jim.Student;

public class QQClient {

    /**

     * @param args

     */

    public static void main(String[] args) {

        // TODO Auto-generated method stub

        System.out.println("Start QQClient...");

        try {

            QQClient client = new QQClient();

        } catch (IOException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

    //构造函数

    public QQClient() throws IOException

    {

        //String address="127.0.0.1";

        //int port = 9999 ;

        try {

            Socket s = new Socket("127.0.0.1", 9999);

            Student stu = new Student("Jim");

            //发送信息给服务器

            ObjectOutputStream oos=new ObjectOutputStream(s.getOutputStream());

            //ObjectInputStream ois=new ObjectInputStream(s.getInputStream());

            //接受服务器传来的信息

            ObjectInputStream ois=new ObjectInputStream(s.getInputStream());

            //发送对象到服务器

            //oos.writeObject(new Student("OKK"));

            oos.writeObject(stu);

            //接收服务器返回的对象

            Student re_stu = (Student)ois.readObject();

            System.out.println(re_stu.getName());

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

}

package com.jim;

public class Student implements java.io.Serializable{

    private String name ;

    private int age;

    private String address;

    public String getName() {

        return name;

    }

    public void setName(String name) {

        this.name = name;

    }

    public int getAge() {

        return age;

    }

    public void setAge(int age) {

        this.age = age;

    }

    public String getAddress() {

        return address;

    }

    public void setAddress(String address) {

        this.address = address;

    }

    /**

     * @param name

     * 构造方法

     */

    public Student(String name){

        this.name = name;

    }

    /**

     * @param

     *

     */

    public void study(){

        System.out.println(this.name + " is studing");

    }

}