java socketServer socket

<div class="iteye-blog-content-contain" style="font-size: 14px"></div>
客户端代码
package serialver.client;

import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInput;
import java.io.ObjectInputStream;
import java.io.ObjectOutput;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

/**
*  @ version 创建时间：2014-3-21 下午03:19:58
*
*  @ author  leicl   
*
*  类说明：
*
*/
public class Client {

public static void main(String[] args) throws UnknownHostException, IOException, ClassNotFoundException {
Socket s = new Socket(InetAddress.getLocalHost(), 2323);
int[] a = {2,3,4,5};
int[] b = {1,1,1,1};
InputStream is = s.getInputStream();
ObjectInput ois = new ObjectInputStream(is);
OutputStream os = s.getOutputStream();
ObjectOutput oos = new ObjectOutputStream(os);

oos.writeObject(a);
oos.writeObject(b);
int[] result = (int[]) ois.readObject();
System.out.println("result got from MathServer:");
for (int i = 0; i < result.length; i++) {
System.out.print(result[i]+"\t");
}
ois.close();
oos.close();
}

}
服务器端代码：
package serialver.server;

import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInput;
import java.io.ObjectInputStream;
import java.io.ObjectOutput;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
*  @ version 创建时间：2014-3-21 下午03:06:52
*
*  @ author  leicl   
*
*  类说明：
*
*/
public class MathServer extends Thread{

public static void main(String[] args) throws IOException {

final ServerSocket ser = new ServerSocket(2323);

new Thread(new Runnable() {
public void run() {
while(true){
try {
final Socket accept = ser.accept();
int[] a = new int[10];
int[] b = new int[10];
int[] result = new int[10];
try {
//此处注意，应该先new ObjectOutput，否则会出现卡死问题
//而且系统捕获不到任何异常
OutputStream os = accept.getOutputStream();
ObjectOutput oos = new ObjectOutputStream(os);
InputStream in = accept.getInputStream();
ObjectInput ois = new ObjectInputStream(in);
a = (int[]) ois.readObject();
b = (int[]) ois.readObject();

for (int i = 0; i < a.length; i++) {
System.out.println("a["+i+"]=" +a[i]);
}
for (int i = 0; i < b.length; i++) {
System.out.println("b["+i+"]=" +b[i]);
}
for (int i = 0; i < b.length; i++) {
result[i] = a[i] + b[i];
}
for (int i = 0; i < result.length; i++) {
System.out.println("result["+i+"]=" +result[i]);
}
oos.writeObject(result);
oos.flush();

ois.close();
oos.close();
} catch (IOException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}).start();
}

}

评论

1 楼 thunderwap 2014-03-21  

这是个人爱好，之前做过RMI的一些工作，现在再次练习一下。