Android之聊天室设计与开发

行是知之始,知是行之成。这篇文章主要讲述Android之聊天室设计与开发相关的知识，希望能为你提供帮助。
我们要设计和实现一个有聊天室功能的APP，需要服务器不断读取来自客户端的信息，并即时地将信息发送给每个连接到本服务器上的客户端，每个客户端可以向服务器发送消息，并不断地接收来自服务器的消息，并将消息显示在界面上。这样就实现了客户端与客户端之间的即时聊天功能。我用草图画了一下及基本流程为：

文章图片

原理与思路：使用TCP面向连接的套接字来建立服务端和客户端两个IP地址端点之间的会画。
服务器端主要完成用户信息的存储、客户端命令的响应与接收、信息的转发等功能。
客户端主要完成登陆、聊天信息的接收以及发送信息等功能。客户端必须在服务器启动后才能连接成功，用户登陆以后聊天室的客户端会显示用户已经登陆，可以与服务器进行即使聊天。
服务器端设计
服务器端是整个聊天室的核心部分，它涵盖了客户端的加入、客户端请求如何处理等一系列功能，客户发送的信息也是通过服务器端发送给其他用户的。
系统的安全性
服务器的安全包括两个部分，一是服务器本身软件和硬件上的安全性，比如防止安全漏洞；而是客户和服务器通讯协议的安全性设计，防止通过协议本身非法攻击服务器。
系统并发服务能力多线程并发处理可以使CPU效率达到最高，举个例子来说，网络的数据传送速率远远低于CPU的处理能力，本地文件系统资源的读写速度也远远低于CPU的处理能力，在传统的单线程环境中，在一个线程程序中如果出现阻塞则整个程序都可以能停止运行，而在一个多线程的程序中就不会出现这样的问题。当一个线程阻塞时，别的线程依然可以大大地提高CPU的效率。
服务器端主要类的定义SerFrame类是服务器端程序的入口，其中包括一个主窗体、若干个容器、按钮和文本框。Init()方法是使整个图形界面初始化。同时还有ServerStart() 方法和ServerStop()两个方法，当运行ServerStart()方法时就会创建一个ServerSocket()对象并设定1001端口号，关闭聊天界面会自动断开连接。
serConnect类集成了Thread线程类，并重写了父类的main()方法。方法中的run()方法一直处于监听状态，直到返回值为false时，也就是服务器关闭时。控制输入输出流来显示在线信息，并发送到用户管理的设计。
服务器端用户管理的设计通过定义UesrInfoList和Node这两个类来实现服务器管理用户功能，当服务器接收到一个客户端的请求，服务器就会初始化一个Node节点作为客户端，Node类中包括输入输出、用户名等必要的属性，还定义了其它自身引用NodeNext，其作用是将客户端设计成链接表，通过这个属性让他们互相连接，这样设计的优点是不需要再定义Map或者List来存放客户端结点，只要在Node中增加一个属性就能够实现，从而提高性能。UserInfoList中定义了对Node结点查找、增加、删除等方法，无论是发送信息、上线、下线和私聊都是调用UserInfoList中的方法来确定对哪个客户端进行操作的。Node对象是存放在内存中的，当ServerSocket关闭的时候会释放资源，Node结点失效。
服务器端消息显示设计服务器端是所有消息中转战和系统消息发出站。在客户端Node类定义两个属性，分别是ObjectOutputStream和ObjectIntputStream，这是java语言的输出输入流，应用所有所有信息的传递。首先ServerListenerThread会捕获到客户端的请求，然后引用ChatRoom类并调用ObjectOutStream方法发送消息。如果是群聊，则调用SendMessage中的SendMsgToAll发送到每一个客户端，并调用UserInfoList来获取所有客户。客户端获得消息后调用服务器中定义的Node类中的OutputStream将接受的显示到图形界面中的文本输出框。若果是私聊，UserInfoList会查找到是哪个用户，再调用SendMessage方法将消息发送到指定客户端。
客服端设计客户端中实现了客户界面的显示以及与服务器端的数据交换，包括接收和发送信息。它继承了Thread线程类，因而多个客户端可以并发执行。
客户端设计准则
客户端作为面对普通的群体，其作用是非常重要的，它的权限没有服务器高。在客户端的设计中只要加入客户端启动界面和发送、接收信息的线程以及一些对基本字符串的简单功能，其他复杂的功能都由服务器来完成。
客户端主要类的定义ChatClient类中定义了客户端的主要函数，login方法是用于用于登陆的，不需要事先注册，用户名不为空即可登陆。另外，还要logout下线以及发送信息的方法。客户端的主界面的初始化写在inti方法中，和服务器端界面类似，它由一个panel和若干个按钮和textArea组成，这些Swing组件与服务器端的监听器相连。
客户端登陆设计程序登陆需要验证，若果用户不是已经存在的用户名，则基本的那个路成功。登陆功能中首先要实例化一个Socket，传入本机的IP地址和连接服务器的端口号，然后congratulationsocket对象获取输入流，实例化用户线程并启用，若果服务器未启动则抛出异常，并在主界面中显示错误信息。
客户端发端发送信息的设计SendMessage方法实现发送信息，该方法首先获得要发送的对象和内容，然后把提示信息、聊天方法、聊天对象、聊天内容和表情依次通过输出流发送给服务器端，发送一条并及时清空一次缓存，服务器会根据接收到的信息作相应的处理。
【Android之聊天室设计与开发】客户端显示收到的消息的设计
ReiMessage方法实现接收消息，该方法中定义了一个while循环，只要用户没有断开与服务器的连接或者下线，则消息一直处于接收状态。当输入流接收服务器发送的内容后，用了条件语句判断是和何种类型的信息，并对其加上相对应的类型提示信息的处理。最后送交主界面进行显示。
创建服务器主类：

package com.home.server; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import java.util.ArrayList; public class MyServer { // 定义保存所有Socket的集合 public static ArrayList< Socket> socketList = new ArrayList< Socket> (); public static void main(String[] args) throws IOException { ServerSocket ss = new ServerSocket(20000); System.out.println("服务器创建成功！"); System.out.println("等待客戶端的连接。。。"); while (true) { // 此行代码会阻塞，等待用户的连接 Socket socket = ss.accept(); System.out.println("有客户端连接进来！"); socketList.add(socket); // 每当客户端连接后启动一条ServerThread线程为该客户端服务 new Thread(new ServerThread(socket)).start(); } } }

Server：

package com.home.server; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import java.util.ArrayList; public class MyServer { // 定义保存所有Socket的集合 public static ArrayList< Socket> socketList = new ArrayList< Socket> (); public static void main(String[] args) throws IOException { ServerSocket ss = new ServerSocket(20000); System.out.println("服务器创建成功！"); System.out.println("等待客戶端的连接。。。"); while (true) { // 此行代码会阻塞，等待用户的连接 Socket socket = ss.accept(); System.out.println("有客户端连接进来！"); socketList.add(socket); // 每当客户端连接后启动一条ServerThread线程为该客户端服务 new Thread(new ServerThread(socket)).start(); } }}

服务器的线程:

package com.home.server; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.Socket; public class ServerThread implements Runnable { // 定义当前线程所处理的Socket private Socket socket = null; // 该线程所处理的Socket所对应的输入流 BufferedReader br = null; public ServerThread(Socket socket) throws IOException { this.socket = socket; // 初始化该Socket对应的输入流 br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "utf-8")); } @Override public void run() { try { String content = null; // 采用循环不断从Socket中读取客户端发送过来的数据 while ((content = readFromClient()) != null) { // 遍历socketList中的每个Socket，将读到的内容向每个Socket发送一次 for (Socket s : MyServer.socketList) { OutputStream os = s.getOutputStream(); os.write((content + "\\n").getBytes("utf-8")); } } } catch (Exception e) { e.printStackTrace(); } }

定义读取客户端数据的方法：

private String readFromClient() { try { return br.readLine(); } // 如果捕捉到异常，表明该Socket对应的客户端已经关闭 catch (Exception e) { // 删除该Socket MyServer.socketList.remove(socket); e.printStackTrace(); } return null; } }

客户端主体类Activity：

package com.home.activity; import java.io.OutputStream; import java.net.Socket; import android.app.Activity; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.view.View; import android.view.View.OnClickListener; import android.widget.Button; import android.widget.EditText; import com.home.R; import com.home.util.ClientThread; public class MultiThreadClient extends Activity { private EditText input, show; private Button sendBtn; private OutputStream os; private Handler handler; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); input = (EditText) findViewById(R.id.main_et_input); show = (EditText) findViewById(R.id.main_et_show); sendBtn = (Button) findViewById(R.id.main_btn_send); handler = new Handler() { @Override public void handleMessage(Message msg) { // 如果消息来自子线程 if (msg.what == 0x234) { // 将读取的内容追加显示在文本框中 show.append("\\n" + msg.obj.toString()); } } }; Socket socket; try { socket = new Socket("192.168.0.101", 20000); // 客户端启动ClientThread线程不断读取来自服务器的数据 new Thread(new ClientThread(socket, handler)).start(); os = socket.getOutputStream(); } catch (Exception e) { e.printStackTrace(); } sendBtn.setOnClickListener(new OnClickListener() { @Override public void onClick(View v) { try { // 将用户在文本框内输入的内容写入网络 os.write((input.getText().toString() + "\\r\\n").getBytes()); // 清空input文本框数据 input.setText(""); } catch (Exception e) { e.printStackTrace(); } } }); } }