网络编程--线程和面向对象的应用--Chat聊天室项目

淩亂°似流年 2022-05-14 02:24 122阅读 0赞

第四篇

Chat聊天室项目

分析：

1.  客户端--多个；服务器--一个

客户端聊天界面的设计

(1)一个多人信息展示界面

(2)个人信息输入界面

2.通信逻辑：多个客户端

客户端a；客户端b；客户端c；客户端d

共同特点：将个人信息发送给服务器，服务器作为信息中转站，将信息发送给所所有客户端。

此时：服务器需要保存所有向客户端的输出流，在发送信息时，遍历所有的输出流，进行发送，客户端在获取信息时，将信息展示到展示界面。

私聊设计：客户端A与客户端B聊天，两个客户端能收到信息，其他客户端收不到信息

私聊格式：

@name:内容

服务端进行判断是否为私聊，如果是私聊应该进行私聊转发信息处理

3.类的设计：

Client类型和Server类型

Client：应该是JFrame的子类

成员变量：Socket socket

**服务端**

package com.hyxy.chat;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.io.OutputStreamWriter;
    import java.io.PrintWriter;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.HashMap;
    import java.util.Map;
    import java.util.Set;
    
    /**
      * 服务端程序设计
     */
    public class Server {
    	private ServerSocket server;
    	/**设计一个集合，用来存储服务端中所有的输出流对象
    	  * 每个客户端的name作为唯一的key
    	  *  对应的向客户端发送数据的输出流作为value 
    	 * */
    	private Map<String,PrintWriter> pws;
    	public Server() {
    		try {
    			server = new ServerSocket(9999);
    			pws = new HashMap<String,PrintWriter>();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	/**
    	  *  保存name-PrintWriter键值对
    	 * @param name   客户端名称
    	 * @param pw     输出流对象
    	 */
    	public void savePw(String name,PrintWriter pw) {
    		if(name!=null&&name.trim().length()!=0) {
    			pws.put(name, pw);
    		}
    	}
    	/**
    	   * 从集合中移除下线的输出流对象
    	 * @param name
    	 */
    	public void removePw(String name) {
    		if(name==null||name.trim().length()==0) {
    			return;
    		}
    		if(pws.containsKey(name)) {
    			pws.remove(name);
    		}
    	}
    	
    	
    	
    	/**服务器启动功能：封装主要逻辑代码*/
    	public void start() {
    		try {
    			while(true) {
    				System.out.println("-----等待客户端连接--------");
    				Socket socket = server.accept();
    				System.out.println("------连接成功----------");
    				
    				/*创建线程对象：处理客户端的信息*/
    				Runnable r = new DealClientInfoHandler(socket);
    				Thread t = new Thread(r);
    				t.start();
    			}
    		
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	public static void main(String[] args) {
    		Server server = new Server();
    		server.start();
    	}
    	class DealClientInfoHandler implements Runnable{
    		private Socket socket;
    		public DealClientInfoHandler(Socket socket) {
    			this.socket = socket;
    		}
    		@Override
    		public void run() {
    			String name= "";
    			try {
    				/*第三步：通信处理*/
    				InputStream is = socket.getInputStream();
    				BufferedReader br = new BufferedReader(
    						new InputStreamReader(is,"utf-8"));
    			    
    				
    				OutputStream os = socket.getOutputStream();
    				PrintWriter pw = new PrintWriter(
    						new OutputStreamWriter(os,"utf-8"),true);
    				
    				/*保存流对象*/
    				name = br.readLine();
    				savePw(name,pw);
    				
    				
    				String line = "";
    			    while((line=br.readLine())!=null) {
    			    	if(!isPrivateChat(line)) {
    			    		//公共聊天
    			    		sendPublicMessage(line);
    			    	}
    			    }
    			} catch (Exception e) {
    				//e.printStackTrace();
    				System.out.println(name+"下线了");
    				sendPublicMessage(name+"下线了");
    				//删除集合中的输出流对象
    				removePw(name);
    			}finally {
    				try {
    					socket.close();
    				} catch (IOException e) {
    					e.printStackTrace();
    				}
    			}
    		}
    		
    	}
    	public boolean isPrivateChat(String line) {
    		if(!line.contains("@")) {
    			return false;
    		}
    		if(line.indexOf(":",line.indexOf("@"))==-1){
    			return false;
    		}
    		int start = line.indexOf("@")+1;
    		int end = line.indexOf(":",start);
    		String substr = line.substring(start, end);
    		if(!pws.containsKey(substr)) {
    			return false;
    		}
    		//是私聊
    		/*获取发言者*/
    		String name = line.substring(0,line.indexOf(":")-1);
    		/*获取发言者说的内容*/
    		String content = line.substring(end+1);
    		
    		pws.get(substr).println(name+"私密我："+content);
    		pws.get(name).println(line);
    		return true;
    	}
    	
    	/**
    	  * 向所有客户端发送信息
    	 * @param message   一个客户端的信息
    	 */
    	public void sendPublicMessage(String message) {
    		Set<String> keys = pws.keySet();
    		for(String name:keys) {
    			pws.get(name).println(message);
    		}
    	}
    }

**客户端**

package com.hyxy.chat;
    
    import java.awt.BorderLayout;
    import java.awt.FlowLayout;
    import java.awt.Font;
    import java.awt.event.KeyAdapter;
    import java.awt.event.KeyEvent;
    import java.awt.event.KeyListener;
    import java.io.BufferedReader;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.io.OutputStreamWriter;
    import java.io.PrintWriter;
    import java.net.Socket;
    
    import javax.swing.JFrame;
    import javax.swing.JPanel;
    import javax.swing.JScrollPane;
    import javax.swing.JTextArea;
    
    /**
      *   客户端程序设计:
      * （1）继承JFrame
     */
    public class Client extends JFrame{
    	private String name;
    	private Socket socket;
    	private JPanel textPanel = new JPanel();
    	private JTextArea showText = new JTextArea(16,42);
    	private JTextArea inputText = new JTextArea(3,42);
    	public Client(String name) {
    		
    		try {
    			this.name = name;
    			this.setTitle(name);//设置窗口的标题
    			socket = new Socket("localhost",9999);
    			setWindowProperty();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	public void setWindowProperty() {
    		this.setSize(500,400);
    		this.setLocationRelativeTo(null);
    		this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
    		this.setResizable(false);//设置窗口不可随意拉伸
    		//先设置窗口的布局模式
    		this.setLayout(new BorderLayout());
    		this.add(textPanel,BorderLayout.CENTER);//将面板添加到布局的中心处
    		//设置面板的布局模式
    		textPanel.setLayout(new FlowLayout());
    		
    		showText.setEditable(false);//设置不可编辑
    		JScrollPane scroll = new JScrollPane(showText);
    		//设置垂直滚动条
    		scroll.setVerticalScrollBarPolicy(
    				JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);
    		
    		textPanel.add(scroll);//注意，将滚动条对象填入面板中
    		
    		
    		
    		inputText.setLineWrap(true);//设置自动换行
    		scroll = new JScrollPane(inputText);
    		scroll.setVerticalScrollBarPolicy(
    				JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);
    		textPanel.add(scroll);
    		this.setVisible(true);
    	}
    	/**客户端主要逻辑的封装*/
    	public void start() {
    		try {
    			sendMessage(name);
    			/*首先：需要创建inputText的监听器*/
    			KeyListener l = new KeyAdapter() {
    				//重写按键释放事件
    				@Override
    				public void keyReleased(KeyEvent e) {
    					if(e.getKeyCode()==KeyEvent.VK_ENTER) {
    						//获取输入文本域的信息内容
    						String info = inputText.getText().trim();
    						//向服务端发送信息
    						
    						sendMessage(name,info);
    						//发送信息后，清空内容
    						inputText.setText(null);
    						
    					}
    				}
    			};
    			inputText.addKeyListener(l);
    			inputText.requestFocus();
    			
    			/*创建线程，处理服务端返回的信息*/
    			Runnable r = new getServerInfoHandler();
    			Thread t = new Thread(r);
    			t.start();
    			
    			
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	/**
    	 *    向服务端发送信息
    	 * @param info   要发送的信息
    	 */
    	public void sendMessage(String name,String info) {
    		if(info==null||info.trim().length()==0) {
    			return;
    		}
    		String message = info.trim();
    		//获取输出流
    		try {
    			OutputStream os = socket.getOutputStream();
    			PrintWriter pw = new PrintWriter(
    					new OutputStreamWriter(os,"utf-8"),true);
    			pw.println(name+"说:"+message);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	/**重载一个方法，用来发送名称*/
    	public void sendMessage(String name) {
    		if(name==null||name.trim().length()==0) {
    			return;
    		}
    		try {
    			OutputStream os = socket.getOutputStream();
    			PrintWriter pw = new PrintWriter(
    					new OutputStreamWriter(os,"utf-8"),true);
    			pw.println(name.trim());
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	
    	
    	
    	public static void main(String[] args) {
    		Client client = new Client("micheal");
    		client.start();
    	}
    	/**
    	 * 定义一个成员内部类，创建接收服务端返
    	 * 回的信息任务体
    	 */
    	class getServerInfoHandler implements Runnable{
    		public void run() {
    			try {
    				InputStream is = socket.getInputStream();
    				BufferedReader br = new BufferedReader(
    						new InputStreamReader(is,"utf-8"));
    				String line = "";
    				while((line=br.readLine())!=null) {
    //					System.out.println("返回信息："+line);
    					showText.append(line+"\r\n");
    					showText.setCaretPosition(
    							showText.getText().length());
    				}
    			} catch (Exception e) {
    				e.printStackTrace();
    			}
    		}
    	}
    	
    	
    	
    }