public class Client {
public static void main(String[] arg) {
try {
Employee joe = new Employee(150, "Joe");
System.out.println("employeeNumber= " + joe.getEmployeeNumber());
System.out.println("employeeName= " + joe.getEmployeeName());
Socket socketConnection = new Socket("127.0.0.1", 11111);
ObjectOutputStream clientOutputStream = new ObjectOutputStream(
socketConnection.getOutputStream());
ObjectInputStream clientInputStream = new ObjectInputStream(
socketConnection.getInputStream());
clientOutputStream.writeObject(joe);
joe = (Employee) clientInputStream.readObject();
System.out.println("employeeNumber= " + joe.getEmployeeNumber());
System.out.println("employeeName= " + joe.getEmployeeName());
clientOutputStream.close();
clientInputStream.close();
} catch (Exception e) {
System.out.println(e);
}
}
}
public static void main(String[] arg) {
try {
Employee joe = new Employee(150, "Joe");
System.out.println("employeeNumber= " + joe.getEmployeeNumber());
System.out.println("employeeName= " + joe.getEmployeeName());
Socket socketConnection = new Socket("127.0.0.1", 11111);
ObjectOutputStream clientOutputStream = new ObjectOutputStream(
socketConnection.getOutputStream());
ObjectInputStream clientInputStream = new ObjectInputStream(
socketConnection.getInputStream());
clientOutputStream.writeObject(joe);
joe = (Employee) clientInputStream.readObject();
System.out.println("employeeNumber= " + joe.getEmployeeNumber());
System.out.println("employeeName= " + joe.getEmployeeName());
clientOutputStream.close();
clientInputStream.close();
} catch (Exception e) {
System.out.println(e);
}
}
}
解决方案 »
- 请教 如何触发ajaxtags select的ajax事件
- MySql怎么连接数据库
- 多次刷新后工程没有反应。struts数据库连接维护。如何让数据库连接效率最大化
- ????ssh框架产生的错误
- 各位大虾,帮帮小弟,第一次发帖.急急急
- 求:各位高手,这两段代码如何写才能让下拉菜单跟我选择的值是一样的
- 请教高手关于JRadius和FReeRadius结合,JRadius对认证和计费包的处理问题
- EJB如何调用?
- 帮我介绍工作,成功入职的,付一月工资做为酬谢(北京地区)
- struts中如何将actionForm中的字符串转换为日期型?
- MyEclipse项目里添加hibernate功能方法的问题
- 求一本或若干本WebService(java)入门的书
public static void main(String[] arg) {
Employee employee = null;
try {
ServerSocket socketConnection = new ServerSocket(11111);
System.out.println("Server Waiting");
Socket pipe = socketConnection.accept();
ObjectInputStream serverInputStream = new ObjectInputStream(pipe
.getInputStream());
ObjectOutputStream serverOutputStream = new ObjectOutputStream(pipe
.getOutputStream());
employee = (Employee) serverInputStream.readObject();
employee.setEmployeeNumber(256);
employee.setEmployeeName("li");
serverOutputStream.writeObject(employee);
serverInputStream.close();
serverOutputStream.close();
} catch (Exception e) {
System.out.println(e);
}
}
}
http://www.java2000.net/p2497
用SocketServer不行吗?
SERVER:
ServerListener(Socket t) throws IOException{
this.socket = t;
in = new ObjectInputStream(socket.getInputStream());
out = new ObjectOutputStream(socket.getOutputStream());
}
public void run() {
dao = new CSDAO();
Opertor[] opertor;
try {
opertor = dao.getAllOpertor();//从数据库获得数据
for(int i=0;i<opertor.length;i++){
out.writeObject(opertor[i]);
}
} catch (Exception e) {}
finally{
try {
in.close();out.close();
} catch (IOException e) {}
}
}
CLIENT:
public ClientConnection(String id) throws CsException, IOException {
address = new NetAddress();
inet = address.getNetAddress(id);
socket = new Socket(inet,1245);
}
public Opertor[] getOpertorName() throws CsException, IOException,ClassNotFoundException {
in = new ObjectInputStream(socket.getInputStream());
out = new ObjectOutputStream(socket.getOutputStream());
Opertor opertor[] = new Opertor[3];//数组为3个,不越界
for(int i=0;i<3;i++){
opertor[i] = (Opertor) in.readObject();
}
in.close();out.close();
return opertor;
}