多用户即时通讯系统03

4.编码实现02

4.4功能实现-私聊功能实现

4.4.1思路分析

客户端 - 发送者：
- 用户在控制台输入信息，客户端接收内容
- 将消息构建成Messgae对象，通过对应的socket发送给服务器
服务器：
- 可以读取到客户端（发送者）发送给某个用户（接收者）的消息
- 从管理线程的集合中，根据messgae对象的信息，获取到接收者的userId，从而获取接收者的socket
- 最后将Message对象转发给指定客户（接收者）
客户端 - 接收者：
- 在接收者的线程（通信线程中），读取到发送者的message消息，并显示即可

4.4.2代码实现

1.客户端

1.MessageClientService类

这里新建一个类，专门用来管理聊天（私聊/群聊）的功能

package qqclient.service;

import qqcommon.Message;

import qqcommon.MessageType;

import java.io.IOException;

import java.io.ObjectOutputStream;

import java.util.Date;

/**

 * @author 李

 * @version 1.0

 * 该类提供和消息（私聊、群聊）相关的服务方法

 */

public class MessageClientService {

    /**

     * @param content  内容

     * @param senderId 发送用户id

     * @param getterId 接收用户id

     */

    public void sendMessageToOne(String content, String senderId, String getterId) {

        //构建 message

        Message message = new Message();

        message.setMesType(MessageType.MESSAGE_COMM_MES);//设置消息类型是普通的聊天类型

        message.setSender(senderId);

        message.setGetter(getterId);

        message.setContent(content);

        message.setSendTime(new Date().toString());//发送时间也封装到message对象中

        System.out.println(senderId + " 对 " + getterId + " 说 " + content);

        //发送给服务端

        try {//在管理线程的集合中，通过userId来获取线程，通过线程来获取对应的socket，再通过socket获取输出流

            ObjectOutputStream oos =

                    new ObjectOutputStream(ManageClientConnectServerThread.getClientConnectServerThread(senderId).getSocket().getOutputStream());

            oos.writeObject(message);

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

}

2.修改：ClientConnectServerThread类

在该类的run方法中修改业务代码，增加else if语句

else if (message.getMesType().equals(MessageType.MESSAGE_COMM_MES)) {

    //接收到的是普通的聊天消息

    //就把服务器转发的消息，显示到控制台即可

    System.out.println(message.getSendTime() + "\n" + message.getSender()

            + " 对" + message.getGetter() + " 说" + message.getContent());

}

3.修改处：QQView类

在类中增加属性messageClientService

private MessageClientService messageClientService = new MessageClientService();//该对象用于私聊/群聊

在类中的内层循环中调用messageClientService对象中的方法

case "3":

    System.out.println("请输入想聊天的用户号（在线）：");

    String getterId = Utility.readString(50);

    System.out.println("请输入想说的话：（100个字符以内）");

    String content = Utility.readString(100);

    //编写一个方法，将消息发送给服务端

    messageClientService.sendMessageToOne(content,userId,getterId);

    break;

2.服务端：

1.修改：ServerConnectClientThread类

在该类中增加方法getSocket()

public Socket getSocket() {

    return socket;

}

在该类中的run方法中增加私聊的业务代码

 else if (message.getMesType().equals(MessageType.MESSAGE_COMM_MES)) {

    //业务三：客户请求和某用户私聊

    //根据message获取getterId，再得到接收者对应的线程

    ServerConnectClientThread serverConnectClientThread =

            ManageClientThreads.getServerConnectClientThread(message.getGetter());

    //得到对应的socket的输出流，将message转发给指定的用户

    ObjectOutputStream oos =

            new ObjectOutputStream(serverConnectClientThread.getSocket().getOutputStream());

    oos.writeObject(message);//转发消息，提示：如果客户不在线，可以保存消息到数据库，实现离线留言

}

运行：

2.客户端：登录三个用户菩提老祖、至尊宝、紫霞仙子，使其相互通信：

用户1：

用户2：

用户3：

day03-3私聊功能的更多相关文章

WUSTOJ的“讨论”和“私聊”功能如何使用
反正我是过了1年多才知道有讨论这个功能,2年多才知道有私聊功能. 不知道大家都是什么时候发现的... 讨论还好,在FAQ界面的下边有提示,但是私聊我真没看到哪儿有提示...是我不小心点进去的. 讨论功 ...
第二个 SignalR，可以私聊的聊天室
一.简介上一次,我们写了个简单的聊天室,接下来,我们来整一个可以私聊的聊天室. SignalR 官方 API 文档需求简单分析: 1.私聊功能,那么要记录用户名或用户ID,用于发送消息. 2.怎么 ...
Vue3 + Socket.io + Knex + TypeScript 实现可以私聊的聊天室
前言下文只在介绍实现的核心代码,没有涉及到具体的实现细节,如果感兴趣可以往下看,在文章最后贴上了仓库地址.项目采用前后端模式,前端使用 Vite + Vue3 + TS:后端使用 Knex + Ex ...
ios项目里扒出来的json文件
p.p1 { margin: 0.0px 0.0px 0.0px 0.0px; font: 13.0px Menlo; color: #000000 } p.p2 { margin: 0.0px 0. ...
ASP.NET程序开发范例宝典
在整理资料时发现一些非常有用的资料源码尤其是初学者,大部分是平时用到的知识点,可以参考其实现方法,分享给大家学习,但请不要用于商业用途. 如果对你有用请多多推荐给其他人分享. 点击对应章节标题下载本章 ...
iOS超全开源框架、项目和学习资料汇总（5）AppleWatch、经典博客、三方开源总结篇
完整项目 v2ex – v2ex 的客户端,新闻.论坛.apps-ios-wikipedia – apps-ios-wikipedia 客户端.jetstream-ios – 一款 Uber 的 MV ...
Github上关于iOS的各种开源项目集合（强烈建议大家收藏，查看，总有一款你需要）
下拉刷新 EGOTableViewPullRefresh - 最早的下拉刷新控件. SVPullToRefresh - 下拉刷新控件. MJRefresh - 仅需一行代码就可以为UITableVie ...
iOS及Mac开源项目和学习资料【超级全面】
UI 下拉刷新 EGOTableViewPullRefresh – 最早的下拉刷新控件. SVPullToRefresh – 下拉刷新控件. MJRefresh – 仅需一行代码就可以为UITable ...
【转】iOS超全开源框架、项目和学习资料汇总
iOS超全开源框架.项目和学习资料汇总(1)UI篇iOS超全开源框架.项目和学习资料汇总(2)动画篇iOS超全开源框架.项目和学习资料汇总(3)网络和Model篇iOS超全开源框架.项目和学习资料汇总 ...

随机推荐

面向个性化需求的在线云数据库混合调优系统 | SIGMOD 2022入选论文解读
SIGMOD 数据管理国际会议是数据库领域具有最高学术地位的国际性会议,位列数据库方向顶级会议之首.近日,腾讯云数据库团队的最新研究成果入选 SIGMOD 2022 Research Full Pap ...
dubbo（九）：timeout超时机制解析
在网络请求时,总会有各种异常情况出现,我们需要提前处理这种情况.在完善的rpc组件dubbo中,自然是不会少了这一层东西的.我们只需要通过一些简单的配置就可以达到超时限制的作用了. dubbo的设计理 ...
挑战30天写操作系统-day2-汇编语言学习与Makefile入门
1.介绍文本编辑器这里,我们直接采用自己windows电脑自带的文本编辑器即可以完成制作要求 2.继续开发下面先是对昨天使用的helloos.nas文件内容进行详细解释 ; hello-os ; ...
下载Chrome离线安装包
https://www.google.com/chrome/thankyou.html?standalone=1&platform=mac&installdataindex=defau ...
IM系统-消息流化一些常见问题
原创不易,求分享.求一键三连之前说过IM系统的一些优化,但是在网络上传输数据对于数据的流化和反流化也是处理异常情况的重点环节,不处理好可能会出现一些消息发送成功,但是解析失败的情况,本文就带大家来一 ...
Mysql 数据恢复流程基于binlog redolog undolog
注:文中有个易混淆的地方 sql事务,即每次数据库操作生成的事务,这个事务trx_id只在undolog里存储,同时undolog维护了此事务是否完成的状态. 日志持久化事务,为了保证redolog和 ...
协程 && 异步例子
# 异步redis # 在使用python代码操作redis的时候,连接.操作.断开都是网络IO. # 安装aioredis模块: pip install aioredis==1.3.1 # 例: 该 ...
PostgreSQL定时备份
# PostgreSQL定时备份 # 版本:PostgreSQL14.0 # 一.如果你在pg_hba.conf中设定了密码登录,那么你就需要设置一个默认密码共psql登录的时候跳过验证.如果是roo ...
SDK和API的直接区别
狭义的说法,在实际工作中, 如果对方需要你提供一个api,是指一个工程提供给另外一个工程的接口(一般是基于http协议). 如果对方需要你提供一个sdk,是指基于对方工程的编程语言,提供一个代码包.在 ...
docker 部署私人 nuget 服务
使用docker搭建私有Nuget服务首先在linux服务器上创建两个容器挂着目录 mkdir /home/nuget/db mkdir /home/nuget/packages 并且对该目录指定写 ...

day03-3私聊功能

多用户即时通讯系统03

4.编码实现02

4.4功能实现-私聊功能实现

4.4.1思路分析

4.4.2代码实现

1.客户端

1.MessageClientService类

2.修改：ClientConnectServerThread类

3.修改处：QQView类

2.服务端：

1.修改：ServerConnectClientThread类

day03-3私聊功能的更多相关文章

随机推荐

热门专题