关于疯狂JAVA中简易聊天客户端的实现流程

简易聊天客户端的实现流程"/>

关于疯狂JAVA中简易聊天客户端的实现流程

         Halo,各位看官老爷们大家好,时隔两个月,我终于闭关回来了.

         今天要给各位看的东西就不得了了,是我多天苦修,终于修成的对一个在CMD界面下的JAVA聊天室的理解!

        首先接触到Socket网络编程的时候.我也是一脸懵逼的,但是其实只要理解了客户端与服务端之间的关系就很好理解了,首先我们要知道的是服务端和客户端其实都是一个Socket实例,ServerSocket的实例的主要含义还是提供一个接口,让客户端与服务端能对接上,每当有客户端请求连接服务端时,ServerSocket的accpet方法总会返回一个与该客户端匹配的Socket进行连接,具体的实现过程可见以下流程图.

        当知道基本的通信过程时,我们就可以开始愉快的编程啦!

        首先上代码,我们需要四个java类来实现基本的群聊操作.

//MyClient类的实现import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;public class MyClient {public static void main(String[] args) throws Exception{Socket s = new Socket("127.0.0.1",40000);new Thread(new ClientSocket(s)).start();BufferedReader br = new BufferedReader(new InputStreamReader(System.in));PrintStream ps = new PrintStream(s.getOutputStream());String content = null;try{while((content = br.readLine())!=null){ps.println(content);}}catch(Exception e ) {e.printStackTrace();}}
}

        这是MyClient类的实现,该类创建了一个客户端,并将客户端连接至服务器,然后通过BufferedReader包装流从键盘获取输入,利用PrintStream包装流向服务端发送从键盘得到的消息.

//ClientThread类的实现import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;public class ClientSocket implements Runnable {private Socket s = null;private BufferedReader br = null;public ClientSocket(Socket s) throws Exception{this.s = s;br = new BufferedReader(new InputStreamReader(s.getInputStream()));}public void run() {String content = null;try {while((content = br.readLine())!= null) {System.out.println(content);}}catch(Exception e){e.printStackTrace();}}
}

       这是ClientThread类的实现,该类实现了Runnable接口,故通过该MyClient类可以创建一个单独的线程监听服务器的反馈,当收到服务器的反馈时,将反馈信息打印至屏幕.也就是实现了聊天室的群聊功能.

//ServerThread类的实现import java.io.*;
import java.net.Socket;public class ServerThread implements Runnable{private Socket s = null;BufferedReader br = null;public ServerThread(Socket s) throws Exception{this.s = s;br = new BufferedReader(new InputStreamReader(s.getInputStream()));}public void run(){String content = null;try{while((content = readFromClient()) != null) {for(Socket s : MyServer.socketList) {PrintStream ps = new PrintStream(s.getOutputStream());ps.println(content);}}}catch(Exception e ) {e.printStackTrace();}}private String readFromClient() {try{return br.readLine();}catch(Exception e ) {MyServer.socketList.remove(s);}return null;}}

        这是ServerThread类的实现,也就是服务器监听线程的实现,该类与ClientThread类有着异曲同工之妙,同样是创建一个线程,只不过这个线程是与客户端的Socket对接,当从一个Socket实例中收到消息时,向所有的Socket客户端发送反馈信息,也就是聊天信息.

//MyServer类的实现import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;public class MyServer {public static List<Socket> socketList = Collections.synchronizedList(new ArrayList<>());public static void main(String[] args) throws Exception{ServerSocket ss = new ServerSocket(40000);while(true) {Socket s = ss.accept();socketList.add(s);new Thread(new ServerThread(s)).start();}}
}

       苦尽甘来!当你能耐着心下来理解到现在,我觉得这个类的实现已经对你不是问题了,同时这也是我们简易聊天室的最后一部,创建一个全局可见的静态线程安全队列,每当ServerSocket收到连接申请时,将accpet返回的Socket实例加入队列中,在ServerThread线程中用于发送全体消息!

       这时候我们就只要运行一个MyServer类,然后运行多个MyClient类就可以看看我们的聊天室功能了,当然我们没有面板,因为穷鸭,没钱买面板(感兴趣的童鞋可以自己完成swing面板的编写),让我们看看效果!

       历经种种,我们还是完成了对这个简易聊天室,很有成就感不是吗!!!那么下一次我的博客会介绍到,如何使用一个只含有标志的接口完成私聊和群聊的聊天室,大家期待吧!走过路过,别忘了点赞哦!