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
最佳实践与提示
- 有多少不同类型的消息就建多少种 Message
- 有多少个消息分发渠道就建多少种 Sender
- 其实 Sender 相当于一个事件处理器(Handler),不要认为只能用来发消息(模板消息,短信等)
- Message 里
setContent()
,setReceiver()
,setTarget()
都不是必须,只是传入对应的参数方便 Sender 中自由的根据消息的来源信息自由修改发送内容