Android实现C/S聊天室

java中能接受其他通信实体链接请求的类是serversocket，serversocket对象用于监听来自客户端的socket链接，如果没有链接，它将一直等待。如果接收到一个客户端socket的连接请求，serversocket的accept()方法将返回一个与客户端socket对应的socket（每个tcp连接有两个socket），否则该方法将一直阻塞，线程也被阻塞。

服务端思路：服务端应该包含多个线程，每个socket对应一个线程，这个线程负责读取该socket对应输入流的数据（从客户端发送过来的数据），并将读到的数据向每个socket输出流发送一次（将一个客户端发送过来的数据“广播”给其他客户端）。

服务端代码：

//服务端主类
public class myserver
{
  public static list<socket> socketlist = collections.synchronizedlist(new arraylist<socket>());
  public static void main(string[] args) throws ioexception
  {
    serversocket ss = new serversocket(30000);
    while (true)
    {
      //此行代码会阻塞，将一直等待别人的连接
      socket s = ss.accept();
      socketlist.add(s);
      //每当客户端连接后启动一个serverthread线程为该客户端服务
      new thread(new serverthread(s)).start();
    }
  }
}

public class serverthread implements runnable
{
  //定义当前线程所处理的socket
  socket s = null;
  //该线程所处理的socket对应的输入流
  bufferedreader br = null;
  public serverthread(socket s) throws ioexception
  {
    this.s = s;
    //初始化该socket对应的输入流
    br = new bufferedreader(new inputstreamreader(s.getinputstream()));
  }

  @override
  public void run()
  {
    try
    {
      string content = null;
      //采用循环不断地从socket中读取客户端发送来的数据
      while ((content = readfromclient()) != null)
      {
        //遍历socketlist中的每个socket
        //将读到的内容向每个socket发送一次
        for (socket s : myserver.socketlist)
        {
          printstream ps = new printstream(s.getoutputstream());
          ps.println(content);
        }
      }
    }
    catch (ioexception e)
    {
      e.printstacktrace();
    }
  }

  //定义读取客户端数据的方法
  private string readfromclient()
  {
    try
    {
      return br.readline();
    }
    //如果捕获到异常，则表明该socket对应的客户端已经关闭
    catch (ioexception e)
    {
      //删除该socket
      myserver.socketlist.remove(s);
    }
    return null;
  }
}

客户端思路：将用户输入的数据写入socket对应的输入流中；开启一个子线程读取socket对应输入流中的数据（从服务端发送过来的数据），并通过handler将读取的数据发送到主线程来更新ui。

//用户界面activity
public class mainactivity extends activity
{
  private edittext mreceivermsg;
  private button msendbtn;
  private edittext msendmsg;
  handler handler = new handler()
  {
    @override
    public void handlemessage(message msg)
    {
      log.d("mainactivity" , "okk");
      mreceivermsg.append(msg.obj.tostring());
    }
  };
  private socket s;
  @override
  protected void oncreate(bundle savedinstancestate)
  {
    super.oncreate(savedinstancestate);
    setcontentview(r.layout.main_activity);

    initview();
    initsocket();
    msendbtn.setonclicklistener(new view.onclicklistener()
    {
      @override
      public void onclick(view view)
      {
        senddata();
      }
    });
  }

  private void initsocket()
  {
    new thread()
    {
      @override
      public void run()
      {
        try
        {
          s = new socket("192.168.1.101" , 30000);
          new thread(new clientthread(s , handler)).start();
        }
        catch (ioexception e)
        {
          e.printstacktrace();
        }
      }
    }.start();
  }

  private void initview()
  {
    mreceivermsg = (edittext) findviewbyid(r.id.receiver_message);
    msendmsg = (edittext) findviewbyid(r.id.send_message);
    msendbtn = (button) findviewbyid(r.id.send_button);
  }

  private void senddata()
  {
    try
    {
      //获取该socket对应的输出流
      printstream ps = new printstream(s.getoutputstream());
      if (textutils.isempty(msendmsg.gettext()))
      {
        toast.maketext(this , "请输入信息" , toast.length_long).show();
        return;
      }
      ps.println(msendmsg.gettext().tostring());
    }
    catch (ioexception e)
    {
      e.printstacktrace();
    }
  }
}

public class clientthread implements runnable
{
  //该线程负责处理的socket
  private socket ss;
  //该线程所处理的socket对应的输入流
  bufferedreader br = null;
  handler handler;
  public clientthread(socket s , handler handler) throws ioexception
  {
    this.ss = s;
    this.handler = handler;
    br = new bufferedreader(new inputstreamreader(ss.getinputstream()));
  }

  @override
  public void run()
  {
    try
    {
      string content = null;
      while ((content = br.readline()) != null)
      {
        message msg = new message();
        msg.obj = content;
        handler.sendmessage(msg);
      }

    }
    catch (ioexception e)
    {
      e.printstacktrace();
    }
  }
}

先运行上面程序中的myserver类，该类运行只是作为服务端。再启动多个模拟器，运行安装客户端的程序作为多个客户端，然后可以再任何一个客户端通过edit输入一些内容，点击发送就可以在任何一个客户端看到刚刚输入的内容。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。