楼主,这是我调通的例子,供你参考。
import java.io.*;
import java.net.*;public class Server1 { public static void main(String[] args) throws Exception {
Socket s = null;
ServerSocket ss = new ServerSocket(8888);
System.out.println("Server started.");
while (true) {
s = ss.accept();
ObjectOutputStream oos = new ObjectOutputStream(new BufferedOutputStream(s.getOutputStream()));
ObjectInputStream ois = new ObjectInputStream(new BufferedInputStream(s.getInputStream())); Message message = (Message) ois.readObject();//接收消息
System.out.println("Received from client: " + message.context); oos.writeObject(message);//发回消息
oos.flush();
oos.close();
ois.close();
if (message == null) {
break;
}
}
s.close();
}
}
///////////////
import java.io.*;
import java.net.*;public class Client1 {
public static void main(String[] args) throws Exception { for (int i = 0; i < 10; i++) {
Socket s = new Socket("localhost", 8888);
ObjectOutputStream oos = new ObjectOutputStream(new BufferedOutputStream(s.getOutputStream()));
Message message = new Message();
message.username = "leeky";
message.password = "leeky";
message.context = "Count " + (i + 1);
oos.writeObject(message);//发送消息
oos.flush();
ObjectInputStream ois = new ObjectInputStream(new BufferedInputStream(s.getInputStream()));
message = (Message) ois.readObject();//读取消息
System.out.println("Received from server: " + message.context);
s.close();
Thread.sleep(1000);
}
}
}
import java.io.*;
import java.net.*;public class Server1 { public static void main(String[] args) throws Exception {
Socket s = null;
ServerSocket ss = new ServerSocket(8888);
System.out.println("Server started.");
while (true) {
s = ss.accept();
ObjectOutputStream oos = new ObjectOutputStream(new BufferedOutputStream(s.getOutputStream()));
ObjectInputStream ois = new ObjectInputStream(new BufferedInputStream(s.getInputStream())); Message message = (Message) ois.readObject();//接收消息
System.out.println("Received from client: " + message.context); oos.writeObject(message);//发回消息
oos.flush();
oos.close();
ois.close();
if (message == null) {
break;
}
}
s.close();
}
}
///////////////
import java.io.*;
import java.net.*;public class Client1 {
public static void main(String[] args) throws Exception { for (int i = 0; i < 10; i++) {
Socket s = new Socket("localhost", 8888);
ObjectOutputStream oos = new ObjectOutputStream(new BufferedOutputStream(s.getOutputStream()));
Message message = new Message();
message.username = "leeky";
message.password = "leeky";
message.context = "Count " + (i + 1);
oos.writeObject(message);//发送消息
oos.flush();
ObjectInputStream ois = new ObjectInputStream(new BufferedInputStream(s.getInputStream()));
message = (Message) ois.readObject();//读取消息
System.out.println("Received from server: " + message.context);
s.close();
Thread.sleep(1000);
}
}
}
解决方案 »
- java的一次编写到处执行现在还好用吗?
- AIX机器上遇到jdbc driver is not on classpath,请大侠指点,谢谢
- 大家给个建议,职称,要怎么考呀.
- 实现页头显示当前用户信息和登出功能
- ftp 下载文件时出现错误!
- 今天先帮她搬了点东西过来,顺便满足yami251139的好奇心
- 安装了JasperIntelligence,还不能正常使用
- j2sdk1.4.2_06+JBOSS4.0.2 每隔两天出现java.lang.OutOfMemoryError错误
- 在WIN2000SERVER怎样运行基于J2EE的JAVA程序?急急…………………!!!!!!!!!!!!!!!!!
- 我将编译好的项目中的一个class文件反编译后修改了
- 有一个关于struts的问题一直困扰着我,找了很久都解决不了问题
- 请问j2ee高手,Struts如何在Action调用SQL语句。
以下是Message
import java.io.*;public class Message
implements Serializable {
public String username = "";
public String password = ""; //消息的发送者
public String sender = ""; //消息的接收者
public String receiver = ""; //消息的内容
public String context = ""; public Message() {
} public void process() { }}
再次感谢usabcd(9号公路上的3名共军) 的帮助