黑马程序员技术交流社区

标题: 分享一个聊天小程序！！！ [打印本页]
作者: myzhang    时间: 2014-9-12 12:07
标题: 分享一个聊天小程序！！！
  1. package socket;
  2. import java.io.*;
  3. import java.net.*;
  4. public class Server extends Thread
  5. {
  6.         ServerSocket skt;
  7.         Socket Client[]=new Socket[10];
  8.         Socket client1=null;
  9.         int i=0;  
  10.         int port,k=0,l=0;
  11.         PrintStream theOutputStream;
  12.         Face chat;
  13.         public Server(int port,Face chat)
  14.         {
  15.                 try
  16.                 {
  17.                         this.port =port;
  18.                         skt=new ServerSocket(port);
  19.                         this.chat=chat;
  20.                 }
  21.                 catch(IOException e)
  22.                 {
  23.                         chat.ta.append(e.toString());
  24.                 }
  25.         }
  26.         public void run()
  27.         {
  28.             chat.ta.append("等待连线......");
  29.                 while(true)
  30.                 {
  31.                         try
  32.                         {
  33.                                 Client[k]=skt.accept();
  34.                                 if (i<2)
  35.                                 {
  36.                                         ServerThread server[] =new ServerThread[10];
  37.                                         server[k]=new ServerThread(Client[k],this.chat,i);
  38.                                         l=server.length;
  39.                                         server[k].start();
  40.                                         chat.ta.append("客户端"+Client[k].getInetAddress()+"已连线\n");
  41.                                         theOutputStream=new PrintStream(server[k].getClient().getOutputStream());
  42.                                         i=server[k].getI();
  43.                                         k++;
  44.                                 }
  45.                                 else
  46.                                 {}
  47.                         }
  48.                         catch (SocketException e)
  49.                         {}
  50.                         catch(IOException e)
  51.                         {
  52.                                 chat.ta.append(e.toString());
  53.                         }
  54.                 }
  55.         }
  56.         public void dataout(String data)
  57.         {
  58.                 theOutputStream.println(data);
  59.         }
  60. }

  62. class ServerThread extends Thread
  63. {
  64.         ServerSocket skt;
  65.         Socket Client;
  66.         int port;
  67.         int i;
  68.         BufferedReader theInputStream;
  69.         PrintStream theOutputStream;
  70.         String readin;
  71.         Face chat;
  72.         public ServerThread(Socket s,Face chat,int i)
  73.         {
  74.                 this.i=++i;
  75.                 Client=s;
  76.                 this.chat=chat;
  77.         }
  78.         public int getI()
  79.         {
  80.                 return this.i;
  81.         }
  82.         public Socket getClient()
  83.         {
  84.                 return this.Client;
  85.         }
  86.         public void run()
  87.         {
  88.                 try
  89.                 {
  90.                         theInputStream=new BufferedReader(new InputStreamReader(Client.getInputStream()));
  91.                         theOutputStream=new PrintStream(Client.getOutputStream());
  92.                         while(true)
  93.                         {
  94.                                 readin=theInputStream.readLine();
  95.                                 chat.ta.append(readin+"\n");
  96.                         }
  97.                 }
  98.                 catch (SocketException e)
  99.                 {
  100.                         chat.ta.append("server连接中断！\n");
  101.                         chat.clientBtn.setEnabled(true);
  102.                         chat.serverBtn.setEnabled(true);
  103.                         chat.tfaddress.setEditable(true);
  104.                         chat.tfport.setEditable(true);
  105.                         try
  106.                         {
  107.                                 i--;
  108.                                 skt.close();//这是第108行，有什么错误啊
  109.                                 Client.close();
  110.                         }
  111.                         catch (IOException err)
  112.                         {
  113.                                 chat.ta.append(err.toString());
  114.                         }
  115.             }
  116.                 catch (IOException e)
  117.                 {
  118.                         chat.ta.append(e.toString());
  119.                 }
  120.         }
  121.         public void dataout(String data)
  122.         {
  123.                 theOutputStream.println(data);
  124.         }
  125. }
复制代码


作者: myzhang    时间: 2014-9-12 12:09
这是服务器端的类，可惜当我关闭客户端时，在服务器端出现如下错误提示： Exception in thread "Thread-4" java.lang.NullPointerException         at socket.ServerThread.run(Server.java:108)
作者: 许文搏    时间: 2014-9-15 16:55
NullPointerException  这是空指针异常  只要见到这个,马上要找一下有没有赋值为空的地方
作者: xiayoutianxia    时间: 2014-9-15 17:26
关闭客户端和服务端需要判断是否为空么？
作者: myzhang    时间: 2014-9-15 23:18
空指针异常！！！



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2