还不错的Java编程的网络聊天室。。。。包含客户端还有client端。。
源代码在线查看: sender.java
package chat.task;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.concurrent.BlockingQueue;
/**
*Socket发送器
*用于将放入队列的信息发送入套接字通道之中。
*/
public class Sender extends Thread {
private BlockingQueue queue;
private ObjectOutputStream out;
/**
* Method SendServicer
*
*
*/
public Sender(Socket socket,BlockingQueue queue)
throws java.io.IOException {
this.queue=queue;
out=new ObjectOutputStream(socket.getOutputStream());
}
/**
* Method run
*
*
*/
public void run(){
while(true){
try{
Object object=queue.take();
out.writeObject(object);
}catch(InterruptedException e){
System.err.println(e.getMessage());
}catch(java.io.IOException e){
break;
}
}
}
}