文本聊天室(TCP)

　　　

　　　　　　　　　　以流式的Socket实现面向连接的TCP服务

---

　　一.功能要求

　　　　　1.用户可以选择聊天服务器进行登录.

　　　　　2.用户使用用户名登录到聊天室，这个登录名就是用户在聊天

　　　　　室的昵称.

　　　　    3.可以选择群聊，广播信息，使所有用户都能看到聊天信息

　　　　　4.可以选择和某个用户私聊,其他用户无法得知聊天内容.

　　　　　5.聊天信息要试试反应到聊天记录中.

　　　　　6.用户登录退出时，要给其他用户发出通知.

---

　　二.设计

　　　　1.界面设计

　　　　　　..........发挥你的想象力.........

　　　　2.整体设计

　　　　　　聊天室整体采用C/S模式,客户端启动后，主动向服务器发出

　　　　　　连接请求，建立Socket连接.服务器启动后，监听固定端口

　　　　　　5210,当有客户连接请求时,便响应此请求,将此连接交由线

　　　　　　程Talking类处理.

　　

---

 

 

　　１．来看服务器的代码实现

package jffx.blogs.net;

import java.io.*;
import java.net.*;
import java.util.*;

/**
 * 代码文件:    TalkRoomServer.java
 * 功能描述:    管理服务器与客户端的活动连接
 */
public class TalkRoomServer {
    public static void main(String[] args) {
        try {
            //服务器端serversocket, 绑定端口(5210), 随意选(1024后的)
            ServerSocket server = new ServerSocket(5210);

            /**
             * 容器来保存服务器与客户端的连接, 键为姓名，值为socket
             */
            Map<String, Socket> socketMap = new HashMap<>() ;

            while(true) {
                //监听客户端的连接, accept的方式是阻塞的
                try {
                    Socket ss = server.accept();

                    //创建流
                    //采用缓冲流,提高效率
                    DataInputStream in = new DataInputStream(
                            new BufferedInputStream(ss.getInputStream())
                    ) ;
                    DataOutputStream out = new DataOutputStream(
                            new BufferedOutputStream(ss.getOutputStream())
                    ) ;

                    /**
                     * 在客户端设计时,一个新的用户登录的同时就向服务器发送其姓名
                     */
                    String name = in.readUTF() ;
                    //获取IP
                    String IP = ss.getInetAddress().toString() ;
                    //显示到服务器
                    System.out.println(name + " : " + IP) ;

                    //查看已监听的客户,并向他们发送新用户登录消息
                    Collection<Socket> values = socketMap.values() ;
                    Iterator<Socket> iter = values.iterator() ;
                    while(iter.hasNext()) {
                        Socket temp = iter.next() ;
                        DataOutputStream write = new DataOutputStream(temp.getOutputStream()) ;
                        write.writeUTF("Add:" + name + IP) ;
                        write.flush() ;
                    }
                    //将新用户添加到容器中
                    socketMap.put(name, ss) ;

                    /**
                     * 向新登录的用户发送都有谁在线
                     */
                    Set<String> names = socketMap.keySet() ;
                    Iterator<String> iterName = names.iterator() ;
                    while(iterName.hasNext()) {
                        String loginUser = iterName.next() ;
                        out.writeUTF("Add:" + loginUser + IP) ;
                        out.flush() ;
                    }


                    /**
                     * 创建新线程转发用户给服务器发送的消息
                     *  由于需要分
                     *      向某个人发送消息，即：私聊
                     *      向所有发送消息，即：广播．
                     *  我们采用修改处理客户端的发送方式：
                     *      在消息的基础上，给前面即消息前缀加上一些表示发送目标的字符串.
                     *      具体看Talking.java的处理方式
                     */
                    //由于客户有可能下线，所以需要将姓名和容器都传递给线程类
                    new Thread(new Talking(name, ss, socketMap)).start() ;

                } catch (Exception ex) {
                    ex.printStackTrace() ;
                }
            }
        } catch (Exception ex) {
            ex.printStackTrace() ;
        }
    }
}

 

 

 

下面这个是单独处理每个用户的线程代码.

　　大概思路是这样的：先读取这个用户的发送的消息，然后进行解析，拆分，

　　　　　　分情况发送给客户端;如果由用户退出了聊天室，将用户从所在的

　　　　　　Socket容器中剔除，并给所有客户发送这个用户退出的消息.

 

 

package jffx.blogs.net;

import java.io.*;
import java.net.*;
import java.util.*;

/**
 * 代码文件:Talking.java
 * 功能描述:线程类转发用户的数据
 */
public class Talking implements Runnable {
    String name ;
    Socket connecter ;
    Map<String, Socket> socketMap = null ;
    public Talking(String name, Socket socket, Map<String, Socket> socketMap) {
        this.name = name ;
        this.connecter = socket ;
        this.socketMap = socketMap ;
    }

    @Override
    public void run() {
        try {
            DataInputStream in = new DataInputStream(
                    new BufferedInputStream(connecter.getInputStream())
            ) ;

            while(true) {
                String words = in.readUTF() ;
                /**
                 * 我们约定，客户端发送("name@text")这种格式的消息
                 * 不过用户不需要处理，我们交由客户端程序在发送消息时自动加上
                 */
                String [] tokens = words.split("@") ;
                String sendName = tokens[0] ;
                String text = tokens[1] ;

                if("All".equals(sendName)) {
                    //容器的值为Socket变量
                    Collection<Socket> sockets = socketMap.values() ;
                    Iterator<Socket> iter = sockets.iterator() ;
                    while(iter.hasNext()) {
                        //创建流.并以固定格式写出
                        Socket sendSocket = iter.next() ;
                        DataOutputStream out = new DataOutputStream(sendSocket.getOutputStream()) ;
                        out.writeUTF("Text:" + text) ;
                        out.flush() ;
                    }
                } else {        //私聊
                    Socket sendSocket = socketMap.get(sendName) ;
                    DataOutputStream out = new DataOutputStream(sendSocket.getOutputStream()) ;
                    out.writeUTF("Text:" + text) ;
                    out.flush() ;
                }
            }
        } catch (Exception ex) {
            ex.printStackTrace() ;
        } finally {                     //当登陆的用户退出后，就会跳出while(true)
            try {
                /**
                 * 查找登陆的用户，删除服务器与其的连接，并发送给所有的客户端
                 */
                this.socketMap.remove(this.name) ;
                Collection<Socket> sockets = this.socketMap.values() ;
                Iterator<Socket> iter = sockets.iterator() ;
                while(iter.hasNext()) {
                    Socket sender = iter.next() ;
                    DataOutputStream out = new DataOutputStream(sender.getOutputStream()) ;
                    out.writeUTF("Del:" + this.name) ;
                    out.flush() ;
                }
            } catch (Exception ex) {
                ex.printStackTrace() ;
            }
        }
    }
}

 

 

至于客户端，留给明天.呵呵...........