前言：昨天我们已经初步学习了网络编程到底是怎么一回事儿，今天在此基础上继续学习网络编程，利用网络编程实现 QQ上的发送消息，群聊，私聊等功能。
首先我们来回顾一下昨天的两点基础知识：
1、建立服务器端
服务器建立通信ServerSocket
服务器建立Socket接收客户端连接
建立IO输入流读取客户端发送的数据
建立IO输出流向客户端发送数据消息
2、建立客户端
创建Socket通信，设置通信服务器的IP和Port
建立IO输出流向服务器发送数据消息
建立IO输入流读取服务器发送来的数据消息
群聊思路分析：
首先我们都知道，群聊是什么形式的，群聊就是一个人发的消息，所有人都可见，但是这要在程序中怎样体现这种关系呢？
首先我们必须明确知道的是，客户端只能向服务器端发送内容，服务器端只能接受客户端发送来的数据，客户端的其他需求可以在发送的字符里面体现。因为QQ的聊天中，分私聊和群聊，所以服务器端就要区分什么内容是群聊什么是私聊，谁私聊谁，为了解决这些问题，我们必须给客户端和服务器端一个统一的规范，这个统一的规范是让服务器端知道发送的是群聊消息还是私聊消息，谁私聊谁的问题。
下面我们定义的规范如下：
例如：p+ wll♥ 晚上好 p+——>服务器译为：私聊wll发送的内容是晚上好
a+ 大家好 a+——> 译为：是群发消息，发送的内容是：大家好
下面我们new一个interface，存放这些规范，如下所示：
//定义一套规范
public interface Chatinterface {
//登录
String LOGIN_FLAG = "u+";
//私聊
String PRIVATE_FLAG="P+";
//群聊
String PUBLIC_FLAG = "a+";
// 分隔符
String SPLTI_FLAG = "♥";
// 成功
String SUCCESS = "1";
//失败
String FAILE = "-1";
}
根据昨天学习的知识，我们知道要定义服务器端和客户端，但是谁来管理登录，私聊群聊呢？所以这里我们要定义一个类来管理。
以下我们定义一个UserManager类来管理，相关注释如下所示：
public class UseraManager {
//保存所有用户的信息
private Map<String, Socket> users = new HashMap<>();
//判断银狐是否已经登录
public boolean isLogined(String name) {
//遍历数组
for (String key : users.keySet()) {
if (key.equals(name)) {
return true;
}
}
return false;
}
//保存当前登录的用户信息
public void save(String name, Socket socket) {
users.put(name, socket);
}
//通过用户名找到对应的socket
public Socket socketName(String name) {
return users.get(name);
}
//通过socket找到对应的名称
public String nameBySocket(Socket socket) {
for (String key : users.keySet()) {
//取出这个key对应的socket
if (socket == users.get(key)) {
return key;
}
}
return null;
}
//获取所有人的socket
public synchronized Collection<Socket> allUsers (){
return users.values();
}
}
`2.建立客户端：
我们知道客户端首先要做的就是建议socket,然后向服务器端发送数据和接收服务器端的数据。第一步：new一个Client类，第二步：创建socket，第三步：创建发送和接收的数据流，格式如下：
//1.创建用于通信的socket
// 指明和谁通信：ip地址 端口号
Socket socket = new Socket("192.168.43.32",8989);
//2. 接收服务器端的数据
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//3.读取服务器端发来的数据
String line = null;
while ((line = br.readLine()) != null){
System.out.println(line);
}
3，多线程，不管是服务器端还是客户端都要接受数据和发送数据，但早发送数据的同时使可以接受数据的，早接收数据的同时，也是可以发送数据的，所以在客户端和服务器端都要使用多线程，服务器端的子线程用来处理客户端发送来的数据：判断是否已经登录，判断是群聊还是私聊，判断私聊给谁，
1.判断是否已经登录如下：
判断用户名是否已经登录
if(Server.manager.isLogined(name)){
//登录过了
ps.println(Chatinterface.FAILE);
} else {
//没有登录过
Server.manager.save(name,socket);
ps.println(Chatinterface.SUCCESS);
}
}
2.判断是不是私聊：
//判断是不是私聊
else if(line.startsWith(Chatinterface.PRIVATE_FLAG)&&line.endsWith(Chatinterface.PRIVATE_FLAG)){
//用户名和聊天内容
//获取信息
int len =line.length()-2;
String msg = line.substring(2,len);
//分割
String[] itens = msg.split(Chatinterface.SPLTI_FLAG) ;
String name = itens[0];
String massage = itens[1];
//通过用户名找到对应的socket
Socket destsocket = Server.manager.socketName(name);
PrintStream desPS = new PrintStream(destsocket.getOutputStream());
//获取当前用户的名称
String currentName = Server.manager.nameBySocket(socket);
//发的送私聊信息
desPS.println(currentName +"想你发来私聊"+massage);
}
因为经过第一步，说明已经登录，经过第二步：说明不是群聊，所以就只用私聊了，处理私聊的大妈如下：
int len =line.length()-2;
String msg = line.substring(2,len);
String currentNmae = Server.manager.nameBySocket(socket);
//遍历所有的用户信息
Collection<Socket> sockets = Server.manager.allUsers();
for(Socket s :sockets){
PrintStream temps = new PrintStream(s.getOutputStream());
temps.println(currentNmae+"发来群聊"+msg);
}
整个代码如下：
客服端：
public class Client {
public static void main(String[] args ){
//BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
BufferedReader br = null;
PrintStream ps = null;
BufferedReader bufferedReader = null;
try ( Socket socket = new Socket("192.168.43.32",8898);){
br = new BufferedReader(new InputStreamReader(System.in));
ps= new PrintStream(socket.getOutputStream());
bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
while (true){
//接受终端输入信息
String line = JOptionPane .showInputDialog("请登录");
// String line = br.readLine();
//拼接登录格式
String loginStr = Chatinterface.LOGIN_FLAG+line+Chatinterface.LOGIN_FLAG;
//发送给服务器
ps.println(loginStr);
//接受服务器端返回的结果
String result = bufferedReader.readLine();
if(result.equals(Chatinterface.SUCCESS)){
System.out.println("登录成功");
break;
}else {
System.out.println("用户已存在,请重新登录");
}
}
//登录成功
//发送数据，接受数据
//开启线程处理服务器端的输入
new ClientThread(socket).start();
String line ;
while ((line = br.readLine())!=null){
ps.println(line);
}
} catch (IOException e) {
}
}
}
子线程：
class ClientThread extends Thread{
private Socket socket ;
public ClientThread(Socket socket ){
this.socket = socket;
}
@Override
public void run() {
BufferedReader br = null;
try{
br= new BufferedReader(new InputStreamReader(socket.getInputStream()));
String line = null;
while ((line = br.readLine())!=null){
System.out.println(line);
}
} catch (IOException e) {
System.out.println("网络出错");
}finally {
try {
if (br != null) {
br.close();
}
if(socket != null){
socket.close();
}
}catch (IOException e) {
}
}
}
}
服务器端：
public class Server {
//用于保存每个与用户姓名和socket
public static UseraManager manager = new UseraManager();
public static void main(String[] args){
try( ServerSocket ss = new ServerSocket(8898);) {
while (true) {
Socket socket = ss.accept();
//让子线程处理这个Socket
new ServerThread(socket).start();
}
} catch (IOException e) {
}
}
}
服务器端子线程：
class ServerThread extends Thread{
private Socket socket;
public ServerThread (Socket socket){
this.socket = socket;
}
@Override
public void run() {
BufferedReader br= null;
PrintStream ps = null;
//登录
//1.获取输入流
try {
br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
ps= new PrintStream(socket.getOutputStream() );
String line =null;
while ((line = br.readLine()) !=null){
if(line.startsWith(Chatinterface.LOGIN_FLAG)&&(line.endsWith(Chatinterface.LOGIN_FLAG))){
// String [] items= line.substring(2).split("u+");
// String name =items[0];
String name = line.substring(2,line.length()-3);
//判断用户名是否已经登录
if(Server.manager.isLogined(name)){
//登录过了
ps.println(Chatinterface.FAILE);
} else {
//没有登录过
Server.manager.save(name,socket);
ps.println(Chatinterface.SUCCESS);
}
}
//判断是不是私聊
else if(line.startsWith(Chatinterface.PRIVATE_FLAG)&&line.endsWith(Chatinterface.PRIVATE_FLAG)){
//用户名和聊天内容
//获取信息
int len =line.length()-2;
String msg = line.substring(2,len);
//分割
String[] itens = msg.split(Chatinterface.SPLTI_FLAG) ;
String name = itens[0];
String massage = itens[1];
//通过用户名找到对应的socket
Socket destsocket = Server.manager.socketName(name);
PrintStream desPS = new PrintStream(destsocket.getOutputStream());
//获取当前用户的名称
String currentName = Server.manager.nameBySocket(socket);
//发的送私聊信息
desPS.println(currentName +"想你发来私聊"+massage);
}else{
int len =line.length()-2;
String msg = line.substring(2,len);
String currentNmae = Server.manager.nameBySocket(socket);
//遍历所有的用户信息
Collection<Socket> sockets = Server.manager.allUsers();
for(Socket s :sockets){
PrintStream temps = new PrintStream(s.getOutputStream());
temps.println(currentNmae+"发来群聊"+msg);
}
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
运行结果：
总结：只是点开始综合了，但是逻辑还是简单的，前面的基础只是有点遗忘的，现在的去看看前面的，有种感觉就是，学习一个只是点的时候不知道他的具体作用，到真正的实战中才能知道对这个只是点到底了解多少，还需要继续努力。
