客户端/服务器端通信：传输对象

本例用java演示在客户端和服务器端传输一个对象，然后打印该对象包含的一些信息。这个程序的基本流程如下图：



先创建一个对象，这个对象包含两个字符串类型的成员，name和message。这个类在被传输之前需要继承可序列化的接口。

import java.io.*;
import java.util.*;

public class TextMessage implements Serializable {
public String name;
public String message;

TextMessage(String n) {
name=n;
message=" ";
}

public String getName() {
return name;
}

public String getTextMessage() {
return message;
}

public void setTextMessage(String inTextMessage) {
message=inTextMessage;
}
}

客户端建立起与服务端的连接，需要使用套接字。套接字指定了互相传输的两台机器的ip地址，端口号与传输协议。然后，客户端创建输出流，输出对象。

import java.io.*;
import java.net.*;

/*
*TextMessage的客户端类
*/
public class Client {
//
public static void main(String[] args) {
// TODO Auto-generated method stub
try {
while(true) {
transferObject();
}

} catch (Exception e) {
System.out.println(e);
}
}

public static void transferObject() throws Exception {
//构建TextMessage对象
TextMessage myTextMessage=buildTextMessage();

//创建套接字连接
Socket socketToServer=new Socket("127.0.0.1",11111);

//创建Object Output Stream
ObjectOutputStream myOutputStream=
new ObjectOutputStream(socketToServer.getOutputStream());
myOutputStream.writeObject(myTextMessage);

//关闭流
myOutputStream.close();
}

public static TextMessage buildTextMessage() throws Exception {
String message=" ";
String name=" ";

System.out.println("please enter name:");
name=getString();
System.out.println("message:");
message=getString();

//创建TextMessage对象
TextMessage myTextMessage=new TextMessage(name);
myTextMessage.setTextMessage(message);

return myTextMessage;
}

public static String getString() throws Exception {
//等待键盘输入（调用‘stdin’）
BufferedReader stdin=
new BufferedReader(new InputStreamReader(System.in),1);
String s1=stdin.readLine();
return s1;
}

}

服务器端通过套接字监听客户端发送的端口，从该端口接受输入流，再从输入流中解析出该对象，并打印。

import java.io.*;
import java.net.*;
/*
*TextMessage的Server类
*/
public class Server {

public static void main(String[] args) {
// TODO Auto-generated method stub

//创建来自客户端的对象的引用
TextMessage myTextMessage=null;

try {
//启动服务并监听端口11111
ServerSocket myServerSocket=new ServerSocket(11111);
System.out.println("Ready\n");

while(true) {
myTextMessage=acceptObject(myServerSocket);
System.out.println(myTextMessage.getName() + ":"
+ myTextMessage.getTextMessage()+"\n");
}
} catch(Exception e) {
System.out.println(e);
}

}
public static TextMessage acceptObject(ServerSocket myServerSocket) throws Exception {
//创建来自客户端的对象的引用
TextMessage myTextMessage=null;

//等待直到有客户端试图连接
Socket incoming=myServerSocket.accept();

//创建ObjectInputStream
ObjectInputStream myInputStream=
new ObjectInputStream(incoming.getInputStream());

//通过套接字读取客户端传输过来的对象
myTextMessage=(TextMessage)myInputStream.readObject();

//关闭流
myInputStream.close();

return myTextMessage;
}
}

运行该实例的方法。IP地址127.0.0.1是回环地址，意味着客户端试图连接的是本地服务器，即可以用同一台机器进行本地测试。一个简单的方法就是用eclipse建立一个工程，将上述代码写在一个包内。Windows环境下，打开两个cmd程序，分别运行Client类和Server类，就能实时查看文本信息传送结果了。

客户端输入信息：



服务器端显示：