有没有人能提供一个java写的socket聊天室小程序

import java.io.*

import java.net.*

public class TestServer{

public static void main(String args[]){

try{

ServerSocket server = null

try{

server = new ServerSocket(3456)

}catch(Exception e){

System.out.println("can not listen to:" + e)

}

Socket socket = null

try{

socket = server.accept()

}catch(Exception e){

System.out.println("Error:" + e)

}

String line

BufferedReader is = new BufferedReader(new InputStreamReader(

socket.getInputStream()))

PrintWriter os = new PrintWriter(socket.getOutputStream())

BufferedReader sin = new BufferedReader(new InputStreamReader(System.in))

System.out.println("Client:" + is.readLine())

line = sin.readLine()

while (!line.equals("bye")){

os.println(line)

os.flush()

System.out.println("Server:" + line)

System.out.println("Client:" + is.readLine())

line = sin.readLine()

}

is.close()

os.close()

socket.close()

server.close()

}catch(Exception e){

System.out.println("Error" + e)

}

}

}

客户端：

import java.io.*

import java.net.*

public class TestClient{

public static void main(String args[]){

try{

Socket socket = new Socket("127.0.0.1",3456)

BufferedReader sin = new BufferedReader(new InputStreamReader(System.in))

PrintWriter os = new PrintWriter(socket.getOutputStream())

BufferedReader is = new BufferedReader(new InputStreamReader(

socket.getInputStream()))

String readline

readline = sin.readLine()

while (!readline.equals("bye")){

os.println(readline)

os.flush()

System.out.println("Client:" + readline)

System.out.println("Server:" + is.readLine())

readline = sin.readLine()

}

os.close()

is.close()

socket.close()

}catch(Exception e){

System.out.println("Error" + e)

}

}

}

要么再看看这个

这个应该可以的拉：

import java.applet.*

import java.awt.*

import java.io.*

import java.net.*

import java.awt.event.*

public class ChatClient extends Applet{

protected boolean loggedIn//登入状态

protected Frame cp//聊天室框架

protected static int PORTNUM=7777//缺省端口号7777

protected int port//实际端口号

protected Socket sock

protected BufferedReader is//用于从sock读取数据的BufferedReader

protected PrintWriter pw//用于向sock写入数据的PrintWriter

protected TextField tf//用于输入的TextField

protected TextArea ta//用于显示对话的TextArea

protected Button lib//登入按钮

protected Button lob//登出的按钮

final static String TITLE ="Chatroom applet>>>>>>>>>>>>>>>>>>>>>>>>"

protected String paintMessage//发表的消息

public ChatParameter Chat

public void init(){

paintMessage="正在生成聊天窗口"

repaint()

cp=new Frame(TITLE)

cp.setLayout(new BorderLayout())

String portNum=getParameter("port")//呢个参数勿太明

port=PORTNUM

if (portNum!=null) //书上是portNum==null,十分有问题

port=Integer.parseInt(portNum)

//CGI

ta=new TextArea(14,80)

ta.setEditable(false)//read only attribute

ta.setFont(new Font("Monospaced",Font.PLAIN,11))

cp.add(BorderLayout.NORTH,ta)

Panel p=new Panel()

Button b

//for login button

p.add(lib=new Button("Login"))

lib.setEnabled(true)

lib.requestFocus()

lib.addActionListener(new ActionListener() {

public void actionPerformed(ActionEvent e){

login()

lib.setEnabled(false)

lob.setEnabled(true)

tf.requestFocus()//将键盘输入锁定再右边的文本框中

}

})

//for logout button

p.add(lob=new Button ("Logout"))

lob.setEnabled(false)

lob.addActionListener(new ActionListener(){

public void actionPerformed(ActionEvent e){

logout()

lib.setEnabled(true)

lob.setEnabled(false)

lib.requestFocus()

}

})

p.add(new Label ("输入消息:"))

tf=new TextField(40)

tf.addActionListener(new ActionListener(){

public void actionPerformed(ActionEvent e){

if(loggedIn){

//pw.println(Chat.CMD_BCAST+tf.getText())//Chat.CMD....是咩野来?

int j=tf.getText().indexOf(":")

if(j>0) pw.println(Chat.CMD_MESG+tf.getText())

else

pw.println(Chat.CMD_BCAST+tf.getText())

tf.setText("")//勿使用flush()?

}

}

})

p.add(tf)

cp.add(BorderLayout.SOUTH,p)

cp.addWindowListener(new WindowAdapter(){

public void windowClosing(WindowEvent e){

//如果执行了setVisible或者dispose,关闭窗口

ChatClient.this.cp.setVisible(false)

ChatClient.this.cp.dispose()

logout()

}

})

cp.pack()//勿明白有咩用?

//将Frame cp放在中间

Dimension us=cp.getSize(),

them=Toolkit.getDefaultToolkit().getScreenSize()

int newX=(them.width-us.width)/2

int newY=(them.height-us.height)/2

cp.setLocation(newX,newY)

cp.setVisible(true)

paintMessage="Window should now be visible"

repaint()

}

//登录聊天室

public void login(){

if(loggedIn) return

try{

sock=new Socket(getCodeBase().getHost(),port)

is=new BufferedReader(new InputStreamReader(sock.getInputStream()))

pw=new PrintWriter(sock.getOutputStream(),true)

}catch(IOException e){

showStatus("Can't get socket: "+e)

cp.add(new Label("Can't get socket: "+e))

return}

//构造并且启动读入器,从服务器读取数据,输出到文本框中

//这里,长成一个线程来避免锁住资源(lockups)

new Thread (new Runnable(){

public void run(){

String line

try{

while(loggedIn &&((line=is.readLine())!=null))

ta.appendText(line+"\n")

}catch(IOException e){

showStatus("我的天啊,掉线了也!!!!")

return

}

}

}).start()

//假定登录(其实只是打印相关信息,并没有真正登录)

// pw.println(Chat.CMD_LOGIN+"AppletUser")

pw.println(Chat.CMD_LOGIN+"AppletUser")

loggedIn =true

}

//模仿退出的代码

public void logout(){

if(!loggedIn)

return

loggedIn=false

try{

if(sock!=null)

sock.close()

}catch(IOException ign){

// 异常处理哦

}

}

//没有设置stop的方法,即使从浏览器跳到另外一个网页的时候

//聊天程序还可以继续运行

public void paint(Graphics g){

Dimension d=getSize()

int h=d.height

int w=d.width

g.fillRect(0,0,w,2)

g.setColor(Color.black)

g.drawString(paintMessage,10,(h/2)-5)

}

}

聊天室服务器端

import java.net.*

import java.io.*

import java.util.*

public class ChatServer{

//聊天室管理员ID

protected final static String CHATMASTER_ID="ChatMaster"

//系统信息的分隔符

protected final static String SEP=": "

//服务器的Socket

protected ServerSocket servSock

//当前客户端列表

protected ArrayList clients

//调试标记

protected boolean DEBUG=false

public ChatParameter Chat

//主方法构造一个ChatServer,没有返回值

public static void main(String[] argv){

System.out.println("Chat server0.1 starting>>>>>>>>>>>>>>>>")

ChatServer w=new ChatServer()

w.runServer()

System.out.println("***ERROR*** Chat server0.1 quitting")

}

//构造和运行一个聊天服务

ChatServer(){

Chat=new ChatParameter()

clients=new ArrayList()

try{

servSock=new ServerSocket(7777)//实有问题拉,不过可能是他自己定义既一个class.

System.out.println("Chat Server0.1 listening on port:"+7777)

}catch(Exception e){

log("IO Exception in ChatServer.<init>")

System.exit(0)

}

}

public void runServer(){

try{

while(true){

Socket us=servSock.accept()

String hostName=us.getInetAddress().getHostName()

System.out.println("Accpeted from "+hostName)

//一个处理的线程

ChatHandler cl=new ChatHandler(us,hostName)

synchronized(clients){

clients.add(cl)

cl.start()

if(clients.size()==1)

cl.send(CHATMASTER_ID,"Welcome!You are the first one here")

else{

cl.send(CHATMASTER_ID,"Welcome!You are the latest of"+

clients.size()+" users.")

}

}

}

}catch(Exception e){

log("IO Exception in runServer:"+e)

System.exit(0)

}

}

protected void log(String s){

System.out.println(s)

}

//处理会话的内部的类

protected class ChatHandler extends Thread {

//客户端scoket

protected Socket clientSock

//读取socket的BufferedReader

protected BufferedReader is

//在socket 上发送信息行的PrintWriter

protected PrintWriter pw

//客户端出主机

protected String clientIP

//句柄

protected String login

public ChatHandler (Socket sock,String clnt)throws IOException {

clientSock=sock

clientIP=clnt

is=new BufferedReader(

new InputStreamReader(sock.getInputStream()))

pw=new PrintWriter (sock.getOutputStream(),true)

}

//每一个ChatHandler是一个线程,下面的是他的run()方法

//用于处理会话

public void run(){

String line

try{

while((line=is.readLine())!=null){

char c=line.charAt(0)//我顶你老母啊 ,果只Chat.CMD咩xx冇定义 扑啊///!!!

line=line.substring(1)

switch(c){

//case Chat.CMD_LOGIN:

case 'l':

if(!Chat.isValidLoginName(line)){

send(CHATMASTER_ID,"LOGIN"+line+"invalid")

log("LOGIN INVALID from:"+clientIP)

continue

}

login=line

broadcast(CHATMASTER_ID,login+" joins us,for a total of"+

clients.size()+" users")

break

// case Chat.CMD_MESG:

case 'm':

if(login==null){

send(CHATMASTER_ID,"please login first")

continue

}

int where =line.indexOf(Chat.SEPARATOR)

String recip=line.substring(0,where)

String mesg=line.substring (where+1)

log("MESG: "+login+"--->"+recip+": "+mesg)

ChatHandler cl=lookup(recip)

if(cl==null)

psend(CHATMASTER_ID,recip+"not logged in.")

else

cl.psend(login,mesg)

break

//case Chat.CMD_QUIT:

case 'q':

broadcast(CHATMASTER_ID,"Goodbye to "+login+"@"+clientIP)

close()

return//ChatHandler结束

// case Chat.CMD_BCAST:

case 'b':

if(login!=null)

broadcast(login,line)

else

log("B<L FROM"+clientIP)

break

default:

log("Unknow cmd"+c+"from"+login+"@"+clientIP)

}

}

}catch(IOException e){

log("IO Exception :"+e)

}finally{

//sock 结束,我们完成了

//还不能发送再见的消息

//得有简单的基于命令的协议才行

System.out.println(login+SEP+"All Done")

synchronized(clients){

clients.remove(this)

if(clients.size()==0){

System.out.println(CHATMASTER_ID+SEP+

"I'm so lonely I could cry>>>>>")

}else if(clients.size()==1){

ChatHandler last=(ChatHandler)clients.get(0)

last.send(CHATMASTER_ID,"Hey,you are talking to yourself again")

}

else{

broadcast(CHATMASTER_ID,"There are now"+clients.size()+" users")

}

}

}

}

protected void close(){

if(clientSock==null){

log("close when not open")

return

}

try{

clientSock.close()

clientSock=null

}catch(IOException e){

log("Failure during close to "+clientIP)

}

}

//发送一条消息给用户

public void send(String sender,String mesg){

pw.println(sender+SEP+"*>"+mesg)

}

//发送私有的消息

protected void psend(String sender ,String msg){

send("<*"+sender+"*>",msg)

}

//发送一条消息给所有的用户

public void broadcast (String sender,String mesg){

System.out.println("Broadcasting"+sender+SEP+mesg)

for(int i=0i<clients.size()i++){

ChatHandler sib=(ChatHandler)clients.get(i)

if(DEBUG)

System.out.println("Sending to"+sib)

sib.send(sender,mesg)

}

if(DEBUG) System.out.println("Done broadcast")

}

protected ChatHandler lookup(String nick){

synchronized(clients){

for(int i=0i<clients.size()i++){

ChatHandler cl=(ChatHandler)clients.get(i)

if(cl.login.equals(nick))

return cl

}

}

return null

}

//将ChatHandler对象转换成一个字符串

public String toString(){

return "ChatHandler["+login+"]"

}

}

}

public class ChatParameter {

public static final char CMD_BCAST='b'

public static final char CMD_LOGIN='l'

public static final char CMD_MESG='m'

public static final char CMD_QUIT='q'

public static final char SEPARATOR=':'//?????

public static final int PORTNUM=7777

public boolean isValidLoginName(String line){

if (line.equals("CHATMASTER_ID"))

return false

return true

}

public void main(String[] argv){

}

}

1.1草图界面，主要实现功能。

1.2 +群聊。

1.3+上线提醒。

1.4+界面优化，仿照QQ2012,+好友上线头像变亮。

1.5+视屏，传文件，表情，装口震动，截图。

我先把1.1的发给你吧。。。

2013年5月31日 13:08:36已发。。