PHP implements notification and message push of knowledge question and answer website

PHP implements the notification system and message push function in the knowledge question and answer website.

With the development of the Internet, knowledge question and answer websites have become more and more popular, providing users with a platform for interactive learning and sharing knowledge. In such a website, a good notification system and message push function are particularly important for users. This article will introduce how to use PHP to implement the notification system and message push function in the knowledge question and answer website.

1. Design and implementation of notification system

1. Database design

In order to store user notification information, we need to design a database table. Assuming we use a MySQL database, we can create a table named notifications with the following fields:

• id: The unique identifier of the notification, set to an auto-incrementing primary key.
• user_id: The user's unique identifier.
• content: The specific content of the notification.
• created_at: The time when the notification was created.

2. Generation and storage of notifications

When the user performs related operations (such as being followed, receiving private messages, new answers to questions, etc.), we need The corresponding notification is generated and stored in the database. The following is an implemented code example:

<?php

function generateNotification($user_id, $content) {
    $sql = "INSERT INTO notifications (user_id, content, created_at) VALUES (?, ?, NOW())";
    // 使用预处理语句减少 SQL 注入风险
    $stmt = $pdo->prepare($sql);
    $stmt->execute([$user_id, $content]);
}

// 生成通知示例
$user_id = 1;
$content = "您的问题有新回答";
generateNotification($user_id, $content);
?>

3. Display and reading of notifications

When users log in to the website, we need to display the user's notifications to them and mark them Have read. The following is a simple code example:

<?php

function getNotifications($user_id) {
    $sql = "SELECT * FROM notifications WHERE user_id = ? ORDER BY created_at DESC";
    $stmt = $pdo->prepare($sql);
    $stmt->execute([$user_id]);
    return $stmt->fetchAll(PDO::FETCH_ASSOC);
}

function markAsRead($notification_id) {
    $sql = "UPDATE notifications SET is_read = 1 WHERE id = ?";
    $stmt = $pdo->prepare($sql);
    $stmt->execute([$notification_id]);
}

// 获取用户通知示例
$user_id = 1;
$notifications = getNotifications($user_id);
foreach ($notifications as $notification) {
    echo $notification['content'];
    markAsRead($notification['id']);
}
?>

2. Design and implementation of message push function

To implement the message push function, we can use the WebSocket protocol and combine it with the Swoole extension of PHP. The following is a simple design and implementation example:

1. First install the Swoole extension and enable the WebSocket function.
2. Create a WebSocket server and monitor user connections:

<?php

$server = new SwooleWebsocketServer("127.0.0.1", 9502);

$server->on('open', function (SwooleWebsocketServer $server, $request) {
    echo "用户 {$request->fd} 连接成功
";
});

$server->on('message', function (SwooleWebsocketServer $server, $frame) {
    echo "收到来自用户 {$frame->fd} 的消息: {$frame->data}
";
});

$server->on('close', function ($ser, $fd) {
    echo "连接关闭：{$fd}
";
});

$server->start();
?>

3. Monitor user operations and send corresponding messages to the client according to business needs:

<?php

$user_id = 1; // 发送消息的用户ID

function pushNotification($user_id, $content) {
    // 向用户发送消息
    // 这里省略具体的代码，可使用 $server->push 方法实现。
}

// 用户操作的代码示例
// ...

// 用户操作后发送消息示例
$content = "您关注的问题有新回答";
pushNotification($user_id, $content);
?>

The above is a simple implementation example of using PHP to implement the notification system and message push function in the knowledge question and answer website. Based on actual needs, you can develop and optimize more complex functions on this basis. Hope this article can be helpful to you!

The above is the detailed content of PHP implements notification and message push of knowledge question and answer website. For more information, please follow other related articles on the PHP Chinese website!