当前位置: 首页 > 文档资料 > ZTBCMS 中文文档 >

3.7 Message

优质
小牛编辑
130浏览
2023-12-01

消息系统

描述:一个系统里面通常都会有一些类似于站内信,用户私信等消息(Message),然后通过邮件,微信模板消息,短信等多种渠道(Sender)发送到对应用户上。消息系统这是解决这个问题。

目录结构

.
├── Controller
├── CronScript 计划任务脚本
├── Install 
├── Libs 核心实现库
├── Messages 消息实体类
├── Model 
├── Senders 发送渠道实现
├── Service 服务
└── Uninstall

使用指南

1.创建你的消息实体类

Message/Messages/ 目录下创建消息实体类,并继承 Message\Libs\Message 类,实现 createSender()


use Message\Libs\Message;
use Message\Model\MessageModel;

class SimpleMessage extends Message {

    /**
     * SimpleMessage constructor.
     *
     * @param string $sender 发送人
     * @param string $receiver 接收人
     * @param string $content  消息ID
     */
    public function __construct($sender, $receiver, $content = '') {
        $this->setContent($content);
        $this->setType(MessageModel::TYPE_MESSAGE); //消息类型本系统没有过多的指定,默认提供 message 私信 和 remind 提醒这两种

        $this->setSender($sender); //发送人,可以是ID,也可以名字,由你的业务决定
        $this->setSenderType('member');//发送人的类型,可以为空,由你的业务决定

        $this->setReceiver($receiver); //接收人,可以是ID,也可以名字,由你的业务决定
        $this->setReceiverType('member'); //接收人的类型,可以为空,由你的业务决定

        $this->setTarget('1');  //消息源,如某某人点赞了一文章,则 Target 可能是文章ID,具体由你的业务决定
        $this->setTargetType('11');//消息源类型,如某某人点赞了一文章,则 Target 应该是文章类型名称,具体由你的业务决定

    }

    /**
     * 定义该消息的消息分发渠道
     *
     * @return array Senders数组
     */
    function createSender() {
        return [
            new SimpleSender(), //示例:发邮件
            new SimpleWxSender() //示例:发微信模板消息
        ];
    }
}

2.创建你的分发渠道

Message/Senders/ 目录下创建消息实体类,并继承 Message\Libs\Sender 类,实现 doSend()

示例:SimpleSender:

class SimpleSender extends Sender {


    /**
     * 发送消息操作
     *
     * @param Message $message
     * @return boolean
     */
    function doSend(Message $message) {
        echo 'simple send => ' . $message->getContent() . '<br>';

        return true;
    }
}

3.创建消息

使用 Message\Service\MessageService::createMessage($msg) 添加消息

use Message\Service\MessageService;

class TestController extends AdminBase {

    //发送信息
    function pushMessage() {
        $sender = 'jayin';
        $receiver = 'admin';
        $content = '用户 ' . $sender . ' 对用户 ' . $receiver . ' 说:' . '你好,这是推送 at ' . date('Y-m-d H:i:s');

        $msg = new SimpleMessage($sender, $receiver, $content);
        MessageService::createMessage($msg);
    }

}

4.消息处理

使用 Message\Service\MessageService::handleMessage($msg_id) 处理(发送)消息

4.1 手动处理一条消息
use Message\Service\MessageService;

class TestController extends AdminBase {

    //处理信息
    function handleMessage() {
        //取出未处理的消息,进行处理
        $messages = D('Message/Message')->where(['process_status' => MessageModel::PROCESS_STATUS_UNPROCESS])->field('id')->select();
        foreach ($messages as $index => $message) {
            MessageService::handleMessage($message['id']);
        }
    }
}
4.2 使用计划任务执行【推荐】

或者你可以添加计划任务,Message/CronScript/HandleMessage,建议每隔1分钟处理一次。执行延迟为分钟级别。

4.3 使用命令行执行【推荐】

使用命令行可以创建多个处理消息进程,可以应付海量的消息处理。执行延迟为秒级别。

# 启动
php index.php /Message/Cli/start 

# 平滑停止(请务必使用这种方式停止,否则任务没有结束就强制结束会有产生系统异常,脏数据等)
php index.php /Message/Cli/stop

最佳实践与提示

  1. 有多少不同类型的消息就建多少种 Message
  2. 有多少个消息分发渠道就建多少种 Sender
  3. 其实 Sender 相当于一个事件处理器(Handler),不要认为只能用来发消息(模板消息,短信等)
  4. Message 里 setContent(), setReceiver(), setTarget() 都不是必须,只是传入对应的参数方便 Sender 中自由的根据消息的来源信息自由修改发送内容