java socket实现聊天室 java实现多人聊天功能

package com.starnet.testserversocket.main;

public class myserversocket {

   public static void main(string[] args) {

     new serverlistener().start();

   }

}

package com.starnet.testserversocket.main;

import java.io.ioexception;

import java.net.serversocket;

import java.net.socket;

import javax.swing.joptionpane;

public class serverlistener extends thread {

   public void run() {

     try {

       serversocket serversocket = new serversocket( 23456 );

       while ( true ) {

         // block

         socket socket = serversocket.accept();

         // 建立链接

         joptionpane.showmessagedialog( null , "有客户端连到本机23456端口" );

         //将socket传递给新的线程

         chatsocket cs= new chatsocket(socket);

         cs.start();

         chatmanager.getchatmanager().add(cs);

       }

     } catch (ioexception e) {

       e.printstacktrace();

     }

   }

}

package com.starnet.testserversocket.main;

import java.io.bufferedreader;

import java.io.ioexception;

import java.io.inputstreamreader;

import java.io.unsupportedencodingexception;

import java.net.socket;

/*每一个连上的客户端，服务器都有一个线程为之服务*/

public class chatsocket extends thread {

   socket socket;

   public chatsocket(socket s) {

     this .socket = s;

   }

   //发送数据

   public void out(string out) {

     try {

       socket.getoutputstream().write(out.getbytes( "utf-8" ));

     } catch (unsupportedencodingexception e) {

       // todo auto-generated catch block

       e.printstacktrace();

     } catch (ioexception e) {

       // todo auto-generated catch block

       e.printstacktrace();

     }

   }

   //服务器会不断地从客户端读取内容，把读取到的内容发给集合内所有的客户端。

   public void run() {

     try {

       //接收数据

       bufferedreader br = new bufferedreader(

           new inputstreamreader(

               socket.getinputstream(), "utf-8" ));

       string line= null ;

       //发送读到的内容

       while ((line = br.readline())!= null ) {

         system.out.println(line);

         chatmanager.getchatmanager().publish( this , line);

       }

       br.close();

     } catch (ioexception e) {

       // todo auto-generated catch block

       e.printstacktrace();

     }

   }

}

package com.starnet.testserversocket.main;

import java.util.vector;

//一个聊天服务器只能有一个manager，要单例化处理

public class chatmanager {

   private chatmanager(){}

   private static final chatmanager cm= new chatmanager();

   public static chatmanager getchatmanager(){

     return cm;

   }

   vector<chatsocket> vector = new vector<chatsocket>();

   /*增加chatsocket 实例到vector中*/

   public void add(chatsocket cs){

     vector.add(cs);

   }

   /*发布消息给其他客户端

    *chatsocket cs： 调用publish的线程

    *msg：要发送的信息 */

   public void publish(chatsocket cs, string msg){

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

       chatsocket cstemp = vector.get(i);

       if (!cs.equals(cstemp)) {

         cstemp.out(msg+ "\n" ); //不用发送给自己。

       }

     }

   }

}

package com.starnet.javaclient.view;

import java.awt.borderlayout;

import java.awt.eventqueue;

import javax.swing.jframe;

import javax.swing.jpanel;

import javax.swing.border.emptyborder;

import javax.swing.jtextarea;

import javax.swing.grouplayout;

import javax.swing.grouplayout.alignment;

import javax.swing.jtextfield;

import javax.swing.jbutton;

import javax.swing.layoutstyle.componentplacement;

import com.starnet.javaclient.main.chatmanager;

import com.sun.xml.internal.ws.client.senderexception;

import java.awt.event.mouseadapter;

import java.awt.event.mouseevent;

public class mainwindow extends jframe {

   /**

    *

    */

   private static final long serialversionuid = 1l;

   private jpanel contentpane;

   private jtextarea txt;

   private jtextfield txtip;

   private jtextfield txtsend;

   /**

    * create the frame.

    */

   public mainwindow() {

     setalwaysontop( true );

     setdefaultcloseoperation(jframe.exit_on_close);

     setbounds( 100 , 100 , 450 , 300 );

     contentpane = new jpanel();

     contentpane.setborder( new emptyborder( 5 , 5 , 5 , 5 ));

     setcontentpane(contentpane);

     txt = new jtextarea();

     txt.settext( "ready..." );

     txtip = new jtextfield();

     txtip.settext( "127.0.0.1" );

     txtip.setcolumns( 10 );

     jbutton btnconnect = new jbutton( "connect" );

     btnconnect.addmouselistener( new mouseadapter() {

       @override

       public void mouseclicked(mouseevent e) {

         chatmanager.getchatmanager().connect(txtip.gettext());

       }

     });

     txtsend = new jtextfield();

     txtsend.settext( "hello" );

     txtsend.setcolumns( 10 );

     jbutton btnsend = new jbutton( "send" );

     btnsend.addmouselistener( new mouseadapter() {

       @override

       public void mouseclicked(mouseevent e) {

         chatmanager.getchatmanager().send(txtsend.gettext());

         appendtext( "我说: " +txtsend.gettext());

         txtsend.settext( "" );

       }

     });

     grouplayout gl_contentpane = new grouplayout(contentpane);

     gl_contentpane.sethorizontalgroup(

       gl_contentpane.createparallelgroup(alignment.leading)

         .addgroup(alignment.trailing, gl_contentpane.createsequentialgroup()

           .addgroup(gl_contentpane.createparallelgroup(alignment.trailing)

             .addgroup(gl_contentpane.createsequentialgroup()

               .addcomponent(txtsend, grouplayout.default_size, 325 , short .max_value)

               .addpreferredgap(componentplacement.related)

               .addcomponent(btnsend, grouplayout.preferred_size, 109 , grouplayout.preferred_size))

             .addgroup(alignment.leading, gl_contentpane.createsequentialgroup()

               .addcomponent(txtip, grouplayout.preferred_size, 294 , grouplayout.preferred_size)

               .addpreferredgap(componentplacement.related)

               .addcomponent(btnconnect, grouplayout.default_size, 140 , short .max_value))

             .addcomponent(txt, grouplayout.default_size, 434 , short .max_value))

           .addcontainergap())

     );

     gl_contentpane.setverticalgroup(

       gl_contentpane.createparallelgroup(alignment.leading)

         .addgroup(gl_contentpane.createsequentialgroup()

           .addgroup(gl_contentpane.createparallelgroup(alignment.baseline)

             .addcomponent(txtip, grouplayout.preferred_size, grouplayout.default_size, grouplayout.preferred_size)

             .addcomponent(btnconnect))

           .addpreferredgap(componentplacement.related)

           .addcomponent(txt, grouplayout.default_size, 198 , short .max_value)

           .addpreferredgap(componentplacement.related)

           .addgroup(gl_contentpane.createparallelgroup(alignment.trailing)

             .addcomponent(btnsend)

             .addcomponent(txtsend, grouplayout.preferred_size, grouplayout.default_size, grouplayout.preferred_size)))

     );

     contentpane.setlayout(gl_contentpane);

   }

   /*客户端发送的内容添加到中间的txt控件中*/

   public void appendtext(string in) {

     txt.append( "\n" + in);

   }

}

package com.starnet.javaclient.main;

import java.awt.eventqueue;

import com.starnet.javaclient.view.mainwindow;

public class startclient {

   public static void main(string[] args) {

     /*先新建一个jframe，然后把自动生成的代码贴过来*/

     eventqueue.invokelater( new runnable() {

       public void run() {

         try {

           mainwindow frame = new mainwindow();

           frame.setvisible( true );

           //创建完这个frame以后，传一份window的引用到chatmanager去

           chatmanager.getchatmanager().setwindow(frame);

         } catch (exception e) {

           e.printstacktrace();

         }

       }

     });

   }

}

package com.starnet.javaclient.main;

import java.io.bufferedreader;

import java.io.ioexception;

import java.io.inputstreamreader;

import java.io.outputstreamwriter;

import java.io.printwriter;

import java.net.socket;

import java.net.unknownhostexception;

import com.starnet.javaclient.view.mainwindow;

public class chatmanager {

   private chatmanager(){}

   private static final chatmanager instance= new chatmanager();

   public static chatmanager getchatmanager(){

     return instance;

   }

   mainwindow window; //为了能在界面上显示服务器发来的信息，就需要传一个mainwindow的引用进来

   socket socket;

   private string ip;

   bufferedreader breader;

   printwriter pwriter;

   public void setwindow(mainwindow window) {

     this .window = window;

     window.appendtext( "文本框已经和chatmanager绑定了" );

   }

   public void connect(string ip) {

     this .ip = ip;

     new thread(){

       @override

       public void run() {

         //实现网络方法

         try {

           socket = new socket(ip, 23456 );

           //输出流

           pwriter = new printwriter(

               new outputstreamwriter(

                   socket.getoutputstream()));

           //输入流

           breader = new bufferedreader(

               new inputstreamreader(

                   socket.getinputstream()));

           string line = null ;

           //如果读取数据为空

           while ((line = breader.readline())!= null ) {

             window.appendtext( "收到： " +line);

           }

           //读完数据之后要关闭

           pwriter.close();

           breader.close();

           pwriter = null ;

           breader = null ;

         } catch (unknownhostexception e) {

           e.printstacktrace();

         } catch (ioexception e) {

           e.printstacktrace();

         }

       }

     }.start();

   }

   public void send(string sendmsg){

     if (pwriter!= null ) {

       pwriter.write(sendmsg+ "\n" );

       pwriter.flush();

     } else {

       window.appendtext( "当前链接已经中断..." );

     }

   }

}