Java消息系统简单设计与实现

前言：由于导师在我的毕设项目里加了消息系统（本来想水水就过的..），没办法...来稍微研究研究吧..简单简单...

需求分析

我的毕设是一个博客系统，类似于简书这样的，所以消息系统也类似，在用户的消息里包含了有：喜欢和赞、评论、关注、私信这样的一类东西，这样的一个系统应该包含以下的功能：

• 1. 当用户评论/关注/点赞时能够通知到被评论/关注/点赞的用户，并生成像如下格式的提示信息（允许取消关注/点赞但不收到通知）：

  我没有 关注了 你
  三颗 喜欢了你的文章 《java消息系统简单设计与实现》
  心脏 评论了你的文章 《java消息系统简单设计与实现》

• 1. 用户之间能够发送/接受私信，不需要像qq那样建立长连接实现实时通信，但刷新列表能看到新消息，并且界面类似qq聊天界面一左一右，允许删除私信；
• 1. 管理员能发送通告，其实就像是用管理员的账号给每一个用户发送私信；
• 1. 可以查看关注的用户最新发表的文章，得到类似推送的效果；
• 1. 所有消息当然也要标注好消息已读or未读，登录就能得到消息提醒标识好有多少未读消息，像是qq消息右上角的小红点那样类似；

ok，大致就是以上的功能，那么问题来了：这要怎么设计啊？

进一步分析

其实可以根据上面的需求分析，把上面的消息大致可以分为公告（announcement）、提醒（remind）、私信（message）三类，我们可以大致抽象出一个 通知（notify） 模型：

发送者	接受者	信息类型	动作类型	通知内容	是否已读	消息创建时间
粉丝1号	我没有三颗心脏	提醒	关注	粉丝1号 关注了 你	是	xx:xx:xx
粉丝1号	我没有三颗心脏	提醒	喜欢和赞	粉丝1号 喜欢了你的文章 《java消息系统简单设计与实现》	是	xx:xx:xx
粉丝1号	我没有三颗心脏	提醒	评论	粉丝1号 评论了你的文章 《java消息系统简单设计与实现》	是	xx:xx:xx
粉丝2号	我没有三颗心脏	私信	无	你收到了来自 粉丝2号 的 1 条私信	是	xx:xx:xx

上面加了一些数据以便理解，不过话说粉丝1号果然是真爱粉，又关注又喜欢又评论，嘻嘻嘻嘻...

emm.这样的模型能够胜任我们的工作吗？我也不知道..不过根据这个模型能够想出大概的这样的创建通知的逻辑：

似乎看上去也没有什么大问题..不过既然消息内容都可以根据动作类型自动生成的了，加上私信和公告的内容因为长度问题也肯定不保存在这张表里的好，所以我们在设计数据库时干脆把通知内容这条去掉不要，当信息类型是公告或者私信时可以根据这条通知的 id 在相应的表中找到相应的数据就可以了，emm..我觉得可以

顺下去想想其实脑中有了一个大概，这样的模型还容易设计和想到，其实主要的问题还是下面的那些

问题一：单表数据大了怎么办？

如果当用户量上去到一定量的时候，那么这张 通知表 势必会变得巨大，因为不管是我们的公告、提醒还是私信都会在这个通知表上创建一条数据，到时候就会面临查询慢的问题，问题的答案是：我也不知道..

所以我们的规定是：不考虑像简书这样超大用户量，能够应付毕设就好啦..简单设计，嘻嘻嘻..不过也不要太不相信mysql的性能，还是有一定容纳能力的！

问题二：用户要怎样正确得到自己的未读消息呢？

暴力一点方法是，反正通知表里有用户所有的消息，直接读取完，然后通过是否已读字段就能够找到正确的所有未读消息了，这..这么简单吗？

其实有思考过使用时间或者另建一张保存有最新已读到哪条消息的表，但用户可以选择有一些读有一些不读，这两个似乎都很难达到目的...还是暴力吧

问题三：私信消息该怎么设计？

发送者	接受者	内容	发送时间
粉丝1号	我没有三颗心脏	我是你的真爱粉啊！我要给你生猴子！	2019年1月7日11:34:23
我没有三颗心脏	粉丝1号	已阅...下一个...	2019年1月7日11:34:53

就像 qq消息 一样嘛，包含一个内容、时间、发送者和接受者，然后前端直接根据时间或者 id 排序生成一左一右的消息对话框，不过比较特殊的一点就是私信是一个双向交流的过程，在一个对话框中我可能既是接受者也是发送者，这也无所谓嘛，稍微分析分析场景：

• 读取私信列表时：按照接受者和发送者一起查询的原则，也就是查询接受者是自己和发送者是自己的数据，然后根据时间和已读未读来建立私信列表；
• 读取私信时：这时已经有了明确的接受者和发送者，那就查询所有 发送者是对方接受者是自己 or 发送者是自己接受者是对方 的数据，然后在前端拼凑出一左一右的聊天框；
• 发送私信时：先查询之前是否有记录，然后同上建立聊天框，点击发送之后把发送方设为自己接收方设为私信对象，然后在通知表中新建一条未读数据通知私信对象有私信来了；

这完全能满足要求，只不过感觉查询多了些..

数据库设计

简单弄了弄弄..看着挺难受的，不过能简单实现功能，并且为了演示，这里是做了一张user_follow表，表示用户之间的关联关系，点赞和评论与这个类似，就不多弄了..下面给一下建表语句吧：

user表：

create table `user` (
  `id` bigint(20) not null auto_increment comment '主键',
  `username` varchar(50) not null comment '用户姓名',
  primary key (`id`)
) engine=innodb auto_increment=5 default charset=utf8;

user_follow表：

create table `user_follow` (
  `id` bigint(20) not null auto_increment comment '主键',
  `uid` bigint(20) not null comment '用户id',
  `follow_uid` bigint(20) not null comment '关注的用户id',
  primary key (`id`)
) engine=innodb default charset=utf8 comment='用户关注表,记录了所有用户的关注信息';

notify表：

create table `notify` (
  `id` bigint(20) not null auto_increment comment '主键',
  `sender_id` bigint(20) not null comment '发送者用户id',
  `reciver_id` bigint(20) not null comment '接受者用户id',
  `type` varchar(50) not null comment '消息类型:announcement公告/remind提醒/message私信',
  `is_read` bit(1) not null default b'0' comment '是否已读,0未读,1已读',
  `create_time` datetime not null default current_timestamp comment '创建时间:按当前时间自动创建',
  primary key (`id`)
) engine=innodb default charset=utf8 comment='用户通知表,包含了所有用户的消息';

message表：

create table `message` (
  `id` bigint(20) not null auto_increment comment '主键',
  `notify_id` bigint(20) not null comment '对应通知消息的id',
  `sender_id` bigint(20) not null comment '发送者用户id',
  `reciver_id` bigint(20) not null comment '接受者用户id',
  `content` varchar(1000) not null comment '消息内容,最长长度不允许超过1000',
  `create_time` datetime not null default current_timestamp comment '创建时间:按当前时间自动创建',
  primary key (`id`)
) engine=innodb default charset=utf8 comment='私信信息表,包含了所有用户的私信信息';

根据《java开发手册》5.3 第六条 没有使用任何级联和外键，bingo！

spring boot + mybatis 实例

第一步：基础环境搭建

springboot项目怎么搭就不说了吧，给一给几个关键的配置文件：

pom包依赖：

<dependency>
    <groupid>org.springframework.boot</groupid>
    <artifactid>spring-boot-starter-web</artifactid>
</dependency>
<dependency>
    <groupid>org.mybatis.spring.boot</groupid>
    <artifactid>mybatis-spring-boot-starter</artifactid>
    <version>1.3.2</version>
</dependency>
<!-- springboot - mybatis 逆向工程 -->
<dependency>
    <groupid>org.mybatis.generator</groupid>
    <artifactid>mybatis-generator-core</artifactid>
    <version>1.3.6</version>
</dependency>
<dependency>
    <groupid>mysql</groupid>
    <artifactid>mysql-connector-java</artifactid>
    <scope>5.1.18</scope>
</dependency>
<dependency>
    <groupid>org.springframework.boot</groupid>
    <artifactid>spring-boot-starter-test</artifactid>
    <scope>test</scope>
</dependency>

这里有一个巨坑，耗费了我好半天的时间，不知道为什么我明明引入的 5.1.18 版本的 mysql-connector-java，可 maven 就是非要给我比较新版本的 8.0.13，这导致了在我使用 mybatis 逆向工程生成 domain 和 mapper 的过程中出现了以下的问题：

• 1、提示我数据库连接的驱动名称需要改成com.mysql.cj.jdbc.driver而不是之前的com.mysql.jdbc.driver，不然就报错：

loading class com.mysql.jdbc.driver'. this is deprecated. the new driver class iscom.mysql.cj.jdbc.driver'. the driver is automatically registered via the spi and manual loading of the driver class is generally unnecessary.

• 2、还需要设置 mysql 的时区，也就是需要将connectionurl属性写成"jdbc:mysql://localhost:3306/test?servertimezone=utc"。如果不指定servertimezone=utc（还必须大写），将报错：

java.sql.sqlexception: the server time zone value '?й???????' is unrecognized or represents more than one time zone. you must configure either the server or jdbc driver (via the servertimezone configuration property) to use a more specifc time zone value if you want to utilize time zone support.
  at com.mysql.cj.jdbc.exceptions.sqlerror.createsqlexception(sqlerror.java:695)
   at com.mysql.cj.jdbc.exceptions.sqlerror.createsqlexception(sqlerror.java:663)

• 3、逆向工程会去找 mysql 其他库的相同表名的表，然后生成一堆乱七八糟的东西，还由于找不到主键 id 生成了只含 inser() 方法而不含删除、更新方法的 mapper 文件；

解决方法就只有自己手动去调低 mysql-connector-java 的版本到 5.xx，还找到一个跟我情况类似：https://blog.csdn.net/angel_xiaa/article/details/52474022

application.properties：

## 数据库连接配置
spring.datasource.driver-class-name=com.mysql.jdbc.driver
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/message_system?characterencoding=utf-8
spring.datasource.username=root
spring.datasource.password=123456
## mybatis相关配置
mybatis.type-aliases-package=com.wmyskxz.demo.messagesystem.domain
mybatis.mapper-locations=classpath:mapper/*.xml

在启动类上加上注解：

@enabletransactionmanagement  // 启注解事务管理，等同于xml配置方式的 <tx:annotation-driven />
@mapperscan("com.wmyskxz.demo.messagesystem.dao")
@springbootapplication
public class messagesystemapplication {
        ....
}

第二步：mybatis 逆向工程

新建【util】包，在下面新建两个类：

mybatisgenerator类：

public class mybatisgenerator {

    public static void main(string[] args) throws exception {
        string today = "2019-1-7";

        simpledateformat sdf = new simpledateformat("yyyy-mm-dd");
        date now = sdf.parse(today);
        date d = new date();

        if (d.gettime() > now.gettime() + 1000 * 60 * 60 * 24) {
            system.err.println("——————未成成功运行——————");
            system.err.println("——————未成成功运行——————");
            system.err.println("本程序具有破坏作用，应该只运行一次，如果必须要再运行，需要修改today变量为今天，如:" + sdf.format(new date()));
            return;
        }

        if (false)
            return;
        list<string> warnings = new arraylist<string>();
        boolean overwrite = true;
        inputstream is = mybatisgenerator.class.getclassloader().getresource("generatorconfig.xml").openstream();
        configurationparser cp = new configurationparser(warnings);
        configuration config = cp.parseconfiguration(is);
        is.close();
        defaultshellcallback callback = new defaultshellcallback(overwrite);
        mybatisgenerator mybatisgenerator = new mybatisgenerator(config, callback, warnings);
        mybatisgenerator.generate(null);

        system.out.println("生成代码成功，只能执行一次，以后执行会覆盖掉mapper,pojo,xml 等文件上做的修改");

    }
}

overismergeableplugin类：

/**
 * 解決 mybatis 逆向工程重复生成覆盖问题的工具类
 */
public class overismergeableplugin extends pluginadapter {
    @override
    public boolean validate(list<string> warnings) {
        return true;
    }

    @override
    public boolean sqlmapgenerated(generatedxmlfile sqlmap, introspectedtable introspectedtable) {
        try {
            field field = sqlmap.getclass().getdeclaredfield("ismergeable");
            field.setaccessible(true);
            field.setboolean(sqlmap, false);
        } catch (exception e) {
            e.printstacktrace();
        }
        return true;
    }
}

在【resrouces】资源文件下新建逆向工程配置文件【generatorconfig.xml】：

<?xml version="1.0" encoding="utf-8"?>
<!doctype generatorconfiguration
        public "-//mybatis.org//dtd mybatis generator configuration 1.0//en"
        "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
<generatorconfiguration>
    <context id="db2tables" targetruntime="mybatis3">

        <!--避免生成重复代码的插件-->
        <plugin type="com.wmyskxz.demo.messagesystem.util.overismergeableplugin"/>

        <!-- 是否去除自动生成的代码中的注释 true：是 false：否-->
        <commentgenerator>
            <property name="suppressdate" value="true"/>
            <property name="suppressallcomments" value="true"/>
        </commentgenerator>

        <!--数据库链接地址账号密码-->
        <jdbcconnection driverclass="com.mysql.jdbc.driver"
                        connectionurl="jdbc:mysql://localhost:3306/message_system?servertimezone=utc"
                        userid="root" password="123456">
        </jdbcconnection>
        <!-- 默认 false，把 jdbc decimal 和 numeric 类型解析为 integer
             为 true 时解析为 java.math.bigdecimal -->
        <javatyperesolver>
            <property name="forcebigdecimals" value="false"/>
        </javatyperesolver>
        <!--生成pojo类存放位置-->
        <javamodelgenerator targetpackage="com.wmyskxz.demo.messagesystem.domain" targetproject="src/main/java">
            <!-- enablesubpackages：是否让 schema 作为包的后缀-->
            <property name="enablesubpackages" value="true"/>
            <!-- trimstrings：从数据库返回的值被清理前后的空格 -->
            <property name="trimstrings" value="true"/>
            <!-- 是否对model添加 构造函数 -->
            <property name="constructorbased" value="true"/>
        </javamodelgenerator>
        <!--生成xml映射文件存放位置-->
        <sqlmapgenerator targetpackage="mapper" targetproject="src/main/resources">
            <property name="enablesubpackages" value="true"/>
        </sqlmapgenerator>
        <!--生成mapper类存放位置-->
        <javaclientgenerator type="xmlmapper" targetpackage="com.wmyskxz.demo.messagesystem.dao"
                             targetproject="src/main/java">
            <property name="enablesubpackages" value="true"/>
        </javaclientgenerator>

        <!--生成对应表及类名
            tablename:要生成的表名
            domainobjectname:生成后的实例名
            enablecountbyexample:count语句中加入where条件查询，默认为true开启
            enableupdatebyexample:update语句中加入where条件查询，默认为true开启
            enabledeletebyexample:delete语句中加入where条件查询，默认为true开启
            enableselectbyexample:select多条语句中加入where条件查询，默认为true开启
            selectbyexamplequeryid:select单个对象语句中加入where条件查询，默认为true开启
        -->
        <table tablename="user" domainobjectname="user" enablecountbyexample="false"
               enableupdatebyexample="false" enabledeletebyexample="false" enableselectbyexample="true"
               selectbyexamplequeryid="false" enabledeletebyprimarykey="true" enableupdatebyprimarykey="true">
            <property name="my.isgen.usekeys" value="true"/>
            <property name="useactualcolumnnames" value="false"/>
            <generatedkey column="id" sqlstatement="jdbc"/>
        </table>
        <table tablename="notify" domainobjectname="notify" enablecountbyexample="false"
               enableupdatebyexample="false" enabledeletebyexample="false" enableselectbyexample="true"
               selectbyexamplequeryid="false" enabledeletebyprimarykey="true" enableupdatebyprimarykey="true">
            <property name="my.isgen.usekeys" value="true"/>
            <property name="useactualcolumnnames" value="false"/>
            <generatedkey column="id" sqlstatement="jdbc"/>
        </table>
        <table tablename="user_follow" domainobjectname="userfollow" enablecountbyexample="false"
               enableupdatebyexample="false" enabledeletebyexample="false" enableselectbyexample="true"
               selectbyexamplequeryid="false" enabledeletebyprimarykey="true" enableupdatebyprimarykey="true">
            <property name="my.isgen.usekeys" value="true"/>
            <property name="useactualcolumnnames" value="false"/>
            <generatedkey column="id" sqlstatement="jdbc"/>
        </table>
        <table tablename="message" domainobjectname="message" enablecountbyexample="false"
               enableupdatebyexample="false" enabledeletebyexample="false" enableselectbyexample="true"
               selectbyexamplequeryid="false" enabledeletebyprimarykey="true" enableupdatebyprimarykey="true">
            <property name="my.isgen.usekeys" value="true"/>
            <property name="useactualcolumnnames" value="false"/>
            <generatedkey column="id" sqlstatement="jdbc"/>
        </table>
    </context>
</generatorconfiguration>

运行我们的【mybatisgenerator】类中的 main 方法就能看到自动生成的实体、xml文件以及 mapper 类

第三步：service 层

不给接口了，直接给实现吧，方法都很简单，而且没有做任何的安全限制，只是为了实现简单的消息系统，看效果

userserviceimpl：

@service
public class userserviceimpl implements userservice {
    @resource
    usermapper usermapper;
    @override
    public void adduserbyusername(string username) {
        usermapper.insert(new user(null, username));// 主键自增长.
    }
    @override
    public user finduserbyid(long id) {
        return usermapper.selectbyprimarykey(id);
    }
}

userfollowserviceimpl：

@service
public class userfollowserviceimpl implements userfollowservice {
    @resource
    userfollowmapper userfollowmapper;
    @autowired
    notifyservice notifyservice;
    @override
    public void userafollowuserbbyid(long useraid, long userbid) {
        // 先要创建一条提示消息
        notifyservice.addnotify(useraid, userbid, "follow");// 关注信息
        userfollow userfollow = new userfollow();
        userfollow.setuid(useraid);
        userfollow.setfollowuid(userbid);
        userfollowmapper.insertselective(userfollow);
    }
    @override
    public void useraunfollowuserbbyid(long useraid, long userbid) {
        // 首先查询到相关的记录
        userfollowexample example = new userfollowexample();
        example.or().anduidequalto(useraid).andfollowuidequalto(userbid);
        userfollow userfollow = userfollowmapper.selectbyexample(example).get(0);
        // 删除关注数据
        userfollowmapper.deletebyprimarykey(userfollow.getid());
    }
}

notifyserviceimpl：

@service
public class notifyserviceimpl implements notifyservice {
    @resource
    notifymapper notifymapper;
    @override
    public int addnotify(long senderid, long reciverid, string type) {
        notify notify = new notify(null, senderid, reciverid, type, false, null);
        return notifymapper.insertselective(notify);// id和creattime自动生成.
    }
    @override
    public void readnotifybyid(long id) {
        notify notify = notifymapper.selectbyprimarykey(id);
        notify.setisread(true);
        notifymapper.updatebyprimarykey(notify);
    }
    @override
    public list<notify> findallnotifybyreciverid(long id) {
        list<notify> notifies = new linkedlist<>();
        notifyexample example = new notifyexample();
        example.setorderbyclause("`id` desc");// 按id倒叙,也就是第一个数据是最新的.
        example.or().andreciveridequalto(id);
        notifies.addall(notifymapper.selectbyexample(example));
        return notifies;
    }
    @override
    public list<notify> findallunreadnotifybyreciverid(long id) {
        list<notify> notifies = new linkedlist<>();
        notifyexample example = new notifyexample();
        example.setorderbyclause("`id` desc");// 按id倒叙,也就是第一个数据是最新的.
        example.or().andreciveridequalto(id).andisreadequalto(false);
        notifies.addall(notifymapper.selectbyexample(example));
        return notifies;
    }
}

messageserviceimpl：

@service
public class messageserviceimpl implements messageservice {
    @resource
    messagemapper messagemapper;
    @resource
    notifyservice notifyservice;
    @override
    public void addmessage(long senderid, long reciverid, string content) {
        // 先创建一条 notify 数据
        long notifyid = (long) notifyservice.addnotify(senderid, reciverid, "message");// message表示私信
        // 增加一条私信信心
        message message = new message(null, notifyid, senderid, reciverid, content, null);
        messagemapper.insertselective(message);// 插入非空项,id/createtime数据库自动生成
    }
    @override
    public void deletemessagebyid(long id) {
        messagemapper.deletebyprimarykey(id);
    }
    @override
    public message findmessagebynotifyid(long id) {
        // 触发方法时应把消息置为已读
        notifyservice.readnotifybyid(id);
        messageexample example = new messageexample();
        example.or().andnotifyidequalto(id);
        return messagemapper.selectbyexample(example).get(0);
    }
}

第四步：controller 层

也很简单，只是为了看效果

usercontroller：

@restcontroller
public class usercontroller {
    @autowired
    userservice userservice;
    @postmapping("/adduser")
    public string adduser(@requestparam string username) {
        userservice.adduserbyusername(username);
        return "success!";
    }
    @getmapping("/finduser")
    public user finduser(@requestparam long id) {
        return userservice.finduserbyid(id);
    }
}

userfollowcontroller ：

@restcontroller
public class userfollowcontroller {
    @autowired
    userfollowservice userfollowservice;
    @postmapping("/follow")
    public string follow(@requestparam long useraid,
                         @requestparam long userbid) {
        userfollowservice.userafollowuserbbyid(useraid, userbid);
        return "success!";
    }
    @postmapping("/unfollow")
    public string unfollow(@requestparam long useraid,
                           @requestparam long userbid) {
        userfollowservice.useraunfollowuserbbyid(useraid, userbid);
        return "success!";
    }
}

notifycontroller ：

@restcontroller
public class notifycontroller {
    @autowired
    notifyservice notifyservice;
    @postmapping("/addnotify")
    public string addnotify(@requestparam long senderid,
                            @requestparam long reciverid,
                            @requestparam string type) {
        notifyservice.addnotify(senderid, reciverid, type);
        return "success!";
    }
    @postmapping("/readnotify")
    public string readnotify(@requestparam long id) {
        notifyservice.readnotifybyid(id);
        return "success!";
    }
    @getmapping("/listallnotify")
    public list<notify> listallnotify(@requestparam long id) {
        return notifyservice.findallnotifybyreciverid(id);
    }
    @getmapping("/listallunreadnotify")
    public list<notify> listallunreadnotify(@requestparam long id) {
        return notifyservice.findallunreadnotifybyreciverid(id);
    }
}

messagecontroller ：

@restcontroller
public class messagecontroller {
    @autowired
    messageservice messageservice;
    @postmapping("/addmessage")
    public string addmessage(@requestparam long senderid,
                             @requestparam long reciverid,
                             @requestparam string content) {
        messageservice.addmessage(senderid, reciverid, content);
        return "success!";
    }
    @deletemapping("/deletemessage")
    public string deletemessage(@requestparam long id) {
        messageservice.deletemessagebyid(id);
        return "success!";
    }
    @getmapping("/findmessage")
    public message findmessage(@requestparam long id) {
        return messageservice.findmessagebynotifyid(id);
    }
}

第五步：测试

通过 rest 测试工具，可以看到正确的效果，这里就不给出所有的测试了。

总结

以上的项目简单而且没有任何的安全验证，不过能够基本完成我们的需求，还有一些功能没有实现，例如管理员发通告（上面只演示了私信和关注信息），按照上面的系统就直接暴力给每个用户都加一条通知消息，感觉有点自闭..我也不知道怎么设计好..希望有经验的大大能指条路啊！

其实关于这个简单的系统我查了好多好多资料..把自己都看自闭了，后来我干脆把所有网页都关掉，开始用 jpa 自己开始抽象实体，把各个实体写出来并把所有实体需要的数据啊相互之间的关联关系啊写清楚，然后再从自动生成的数据库中找思路...hhh...要不是我 jpa 不是很熟我觉得用 jpa 就能写出来了，不用 jpa 的原因在于一些数据的懒加载不知道怎么处理，还有就是查询语句太复杂，免不了要浪费一些资源...emmm..说到底还是不是特别懂 jpa，下面给一张复杂的用 jpa 建立的 user 实体吧（随手截的..hhh...很乱..）：

---

按照惯例黏一个尾巴：

欢迎转载，转载请注明出处！
简书id：
github：
欢迎关注公众微信号：wmyskxz
分享自己的学习 & 学习资料 & 生活
想要交流的朋友也可以加qq群：3382693