当前位置: 首页 > 编程笔记 >

Android实现C/S聊天室

奚无尘
2023-03-14
本文向大家介绍Android实现C/S聊天室,包括了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输入一些内容,点击发送就可以在任何一个客户端看到刚刚输入的内容。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持小牛知识库。

 类似资料:
  • 本文向大家介绍Android实现简单C/S聊天室应用,包括了Android实现简单C/S聊天室应用的使用技巧和注意事项,需要的朋友参考一下 Android的网络应用:简单的C/S聊天室,供大家参考,具体内容如下 服务器端:提供两个类 创建ServerSocket监听的主类:MyServer.java 负责处理每个Socket通信的线程类:ServerThread.java 客户端:是一个Andro

  • 本文向大家介绍Python socket C/S结构的聊天室应用实现,包括了Python socket C/S结构的聊天室应用实现的使用技巧和注意事项,需要的朋友参考一下 Python socket C/S结构的聊天室应用 服务端: 客户端:

  • 本文向大家介绍Android基于socket实现的简单C/S聊天通信功能,包括了Android基于socket实现的简单C/S聊天通信功能的使用技巧和注意事项,需要的朋友参考一下 本文实例讲述了Android基于socket实现的简单C/S聊天通信功能。分享给大家供大家参考,具体如下: 主要想法:在客户端上发送一条信息,在后台开辟一个线程充当服务端,收到消息就立即回馈给客户端。 第一步:创建一个继

  • 本文向大家介绍Android使用Websocket实现聊天室,包括了Android使用Websocket实现聊天室的使用技巧和注意事项,需要的朋友参考一下 最近的项目中要实现一个聊天的功能,类似于斗鱼TV的聊天室功能,与服务器端人商量后决定用WebSocket来做,但是在这之前我只知道Socket但是听都没有听过WebSocket,但是查看了相关的材料以后发现实现一个聊天室其实是很简单的!下面我们

  • 本文向大家介绍Android实现蓝牙聊天功能,包括了Android实现蓝牙聊天功能的使用技巧和注意事项,需要的朋友参考一下 蓝牙,时下最流行的智能设备传输数据的方式之一,通过手机app和智能设备进行连接,获取设备上的测量数据,我们生活中随处可见的比如蓝牙智能手环,蓝牙电子秤,蓝牙心电测量设备等等。 本篇我将紧接着上篇结尾所写,一起来看下手机之间如何通过蓝牙实现文字聊天。 先贴出上篇的一些demo;

  • 我是节点js&socket.io的新手。给我一个如何解决这个问题的架构指南。提亚。 我的app.js代码: