程序下载 · 部署教程 · 使用教程 · 意见反馈 · 在线演示
公告:官方部署站 https://msgpusher.com 现已上线,当前开放注册,欢迎使用。如果收到积极反馈未来可以考虑换用延迟更低的服务器。
- 多种消息推送方式:
- 多种用户登录注册方式:
- 邮箱登录注册以及通过邮箱进行密码重置。
- GitHub 开放授权。
- 微信公众号授权(需要额外部署 WeChat Server)。
- 支持 Markdown。
- 支持用户管理。
- Cloudflare Turnstile 用户校验。
- 支持在线发布公告,设置关于界面以及页脚。
- 支持在 Web 端管理发送的消息,支持自动刷新。
- 整合进自己的博客系统,每当有人登录时发微信消息提醒。
- 在进行深度学习模型训练时,在每个 epoch 结束后将关键数据发送到微信以方便及时监控。
- 在各种脚本运行结束后发消息提醒,例如监控 GitHub Star 数量的脚本,又例如自动健康填报的脚本,用来通知运行结果。
- 为其他系统提供消息推送功能。
- 从 GitHub Releases 下载可执行文件或者从源码编译:
git clone https://github.com/songquanpeng/message-pusher.git go mod download go build -ldflags "-s -w" -o message-pusher
- 运行:
chmod u+x message-pusher ./message-pusher --port 3000 --log-dir ./logs
- 访问 https://localhost:3000/ 并登录。初始账号用户名为
root
,密码为123456
。
如果服务需要长久运行,只是单纯地启动是不够的,详细部署教程。
部署:docker run -d --restart always --name message-pusher -p 3000:3000 -e TZ=Asia/Shanghai -v /home/ubuntu/data/message-pusher:/data justsong/message-pusher
更新:docker run --rm -v /var/run/docker.sock:/var/run/docker.sock containrrr/watchtower -cR
开放的端口号为 3000,之后用 Nginx 配置域名,反代以及 SSL 证书即可,具体参考详细部署教程。
数据将会保存在宿主机的 /home/ubuntu/data/message-pusher
目录(只有一个 SQLite 数据库文件)。
如果需要使用 WebSocket 客户端推送功能,则 Nginx 的配置文件中 proxy_read_timeout
和 proxy_send_timeout
务必设置超过 1 分钟。
推荐设置:
proxy_read_timeout 300s;
proxy_send_timeout 300s;
系统本身仅需要下载一个可执行文件即可开始使用,无其他依赖。
你可以通过设置环境变量或者命令行参数进行配置。
等到系统启动后,使用 root
用户登录系统并做进一步的配置,默认密码为 123456
。
REDIS_CONN_STRING
:设置之后将使用 Redis 作为请求频率限制的存储,而非使用内存存储。- 例子:
REDIS_CONN_STRING=redis:https://default:redispw@localhost:49153
- 例子:
SESSION_SECRET
:设置之后将使用固定的会话密钥,这样系统重新启动后已登录用户的 cookie 将依旧有效。- 例子:
SESSION_SECRET=random_string
- 例子:
SQL_DSN
:设置之后将使用指定数据库而非 SQLite。- 例子:
SQL_DSN=root:123456@tcp(localhost:3306)/message-pusher
- 例子:
注意:使用 Docker 部署时,请使用 -e key=value
设置环境变量。
例子:docker run -e SESSION_SECRET=random_string ...
--port <port_number>
: 指定服务器监听的端口号,默认为3000
。- 例子:
--port 3000
- 例子:
--log-dir <log_dir>
: 指定日志文件夹,如果没有设置,日志将不会被保存。- 例子:
--log-dir ./logs
- 例子:
--version
: 打印系统版本号并退出。
- 系统设置:
- 填写服务器地址。
- 配置登录注册选项,如果系统不对外开发,请取消选择
允许新用户注册
。 - 配置 SMTP 服务,可以使用 QQ 邮箱的 SMTP 服务。
- 其他配置可选,请按照页面上的指示完成配置。
- 个人设置:
- 点击
更新用户信息
更改默认用户名和密码。 - 点击
绑定邮箱地址
绑定邮箱以启用邮件消息推送方式。
- 点击
- 推送设置:
- 设置
默认推送方式
,默认为通过邮件进行推送。 - 设置
推送 token
,用以推送 API 调用鉴权,如果不需要留空即可。 - 设置其他推送方式,按照页面上的指示即可,完成配置后点击对应的
测试
按钮即可测试配置是否成功。
- 设置
- 其他设置:如果系统对外提供服务,本系统也提供了一定的个性化设置功能,你可以设置关于界面和页脚,以及发布公告。
- 消息推送 API URL:
https://<domain>/push/<username>
- 将上面的
<domain>
以及<username>
替换为真实值,例如:https://push.mydomain.cn/push/admin
- 将上面的
GET
请求方式:https://<domain>/push/<username>?title=<标题>&description=<描述>&content=<Markdown 文本>&channel=<推送方式>&token=<推送 token>
title
:选填,受限于具体的消息推送方式,其可能被忽略。description
:必填,可以替换为desp
。content
:选填,受限于具体的消息推送方式,Markdown 语法的支持有所区别。channel
:选填,如果不填则系统使用你在后台设置的默认推送方式。可选的推送方式有:email
:通过发送邮件的方式进行推送(使用title
或description
字段设置邮件主题,使用content
字段设置正文,支持完整的 Markdown 语法)。test
:通过微信测试号进行推送(使用description
字段设置模板消息内容,不支持 Markdown)。corp_app
:通过企业微信应用号进行推送(仅当使用企业微信 APP 时,如果设置了content
字段,title
和description
字段会被忽略;使用微信中的企业微信插件时正常)。corp
:通过企业微信群机器人推送(设置content
字段则将渲染 Markdown 消息,支持 Markdown 的子集;设置description
字段则为普通文本消息)。lark
:通过飞书群机器人进行推送(注意事项同上)。ding
:通过钉钉群机器人进行推送(注意事项同上)。bark
:通过 Bark 进行推送(支持title
和description
字段)。client
:通过 WebSocket 客户端进行推送(支持title
和description
字段)。telegram
:通过 Telegram 机器人进行推送(description
或content
字段二选一,支持 Markdown 的子集)。discord
:通过 Discord 群机器人进行推送(注意事项同上)。none
:仅保存到数据库,不做推送。
token
:如果你在后台设置了推送 token,则此项必填。另外可以通过设置 HTTPAuthorization
头部设置此项。url
:选填,如果不填则系统自动为消息生成 URL,其内容为消息详情。to
:选填,推送给指定用户,如果不填则默认推送给自己,受限于具体的消息推送方式,有些推送方式不支持此项。@all
:推送给所有用户。user1|user2|user3
:推送给多个用户,用户之间使用|
分隔。
POST
请求方式:字段与上面GET
请求方式保持一致。- 注意:请求体编码格式为
application/json
,v0.3.2
版本起支持 Post Form。
- 注意:请求体编码格式为
示例:
Bash 示例
#!/bin/bash
MESSAGE_PUSHER_SERVER="https://msgpusher.com"
MESSAGE_PUSHER_USERNAME="test"
MESSAGE_PUSHER_TOKEN="666"
function send_message {
# POST Form
curl -s -X POST "$MESSAGE_PUSHER_SERVER/push/$MESSAGE_PUSHER_USERNAME" \
-d "title=$1&description=$2&content=$3&token=$MESSAGE_PUSHER_TOKEN" \
>/dev/null
}
function send_message_with_json {
# POST JSON
curl -s -X POST "$MESSAGE_PUSHER_SERVER/push/$MESSAGE_PUSHER_USERNAME" \
-H 'Content-Type: application/json' \
-d '{"title":"'"$1"'","desp":"'"$2"'", "content":"'"$3"'", "token":"'"$MESSAGE_PUSHER_TOKEN"'"}' \
>/dev/null
}
send_message 'title' 'description' 'content'
Python 示例
import requests
SERVER = "https://msgpusher.com"
USERNAME = "test"
TOKEN = "666"
def send_message(title, description, content):
# GET 方式
# res = requests.get(f"{SERVER}/push/{USERNAME}?title={title}"
# f"&description={description}&content={content}&token={TOKEN}")
# POST 方式
res = requests.post(f"{SERVER}/push/{USERNAME}", json={
"title": title,
"description": description,
"content": content,
"token": TOKEN
})
res = res.json()
if res["success"]:
return None
else:
return res["message"]
error = send_message("标题", "描述", "**Markdown 内容**")
if error:
print(error)
Go 示例
package main
import (
"bytes"
"encoding/json"
"errors"
"fmt"
"net/http"
"net/url"
)
var serverAddress = "https://msgpusher.com"
var username = "test"
var token = "666"
type request struct {
Title string `json:"title"`
Description string `json:"description"`
Content string `json:"content"`
URL string `json:"url"`
Channel string `json:"channel"`
Token string `json:"token"`
}
type response struct {
Success bool `json:"success"`
Message string `json:"message"`
}
func SendMessage(title string, description string, content string) error {
req := request{
Title: title,
Description: description,
Content: content,
Token: token,
}
data, err := json.Marshal(req)
if err != nil {
return err
}
resp, err := http.Post(fmt.Sprintf("%s/push/%s", serverAddress, username),
"application/json", bytes.NewBuffer(data))
if err != nil {
return err
}
var res response
err = json.NewDecoder(resp.Body).Decode(&res)
if err != nil {
return err
}
if !res.Success {
return errors.New(res.Message)
}
return nil
}
func SendMessageWithForm(title string, description string, content string) error {
resp, err := http.PostForm(fmt.Sprintf("%s/push/%s", serverAddress, username),
url.Values{"title": {title}, "description": {description}, "content": {content}, "token": {token}})
if err != nil {
return err
}
var res response
err = json.NewDecoder(resp.Body).Decode(&res)
if err != nil {
return err
}
if !res.Success {
return errors.New(res.Message)
}
return nil
}
func main() {
//err := SendMessage("标题", "描述", "**Markdown 内容**")
err := SendMessageWithForm("标题", "描述", "**Markdown 内容**")
if err != nil {
fmt.Println("推送失败:" + err.Error())
} else {
fmt.Println("推送成功!")
}
}
C# 示例
using Newtonsoft.Json;
using RestSharp;
namespace Demo
{
public class Program
{
public static void Main(string[] args)
{
//推送消息
var sendMsg = MessagePusherTool.SendMessage("标题", "描述", "**Markdown 内容**");
if(sendMsg.Success)
{
Console.WriteLine($"推送成功!");
}
else
{
Console.WriteLine($"推送失败:{sendMsg.Message}");
}
}
}
/// <summary>
/// 消息推送工具
///
/// <para>开源地址:https://github.com/songquanpeng/message-pusher</para>
/// <para>支持:Framework、Net3.1、Net5、Net6</para>
/// <para>引用包:</para>
/// <para>dotnet add package Newtonsoft.Json -v 13.0.2</para>
/// <para>dotnet add package RestSharp -v 108.0.3</para>
/// </summary>
public class MessagePusherTool
{
/// <summary>
/// ServerAddress
/// </summary>
public const string ServerAddress = "https://msgpusher.com";
/// <summary>
/// UserName
/// </summary>
public const string UserName = "test";
/// <summary>
/// Token
/// </summary>
public const string Token = "666";
/// <summary>
/// SendMessage
/// </summary>
/// <param name="title">title</param>
/// <param name="description">description</param>
/// <param name="content">content</param>
public static Response SendMessage(string title, string description, string content)
{
var requestData = new Request()
{
Title = title,
Description = description,
Content = content,
Token = Token,
};
var url = $"{ServerAddress}";
var client = new RestClient(url);
var request = new RestRequest($"push/{UserName}", Method.Post);
request.AddJsonBody(requestData);
var response = client.Execute(request);
var responseData = response.Content;
var responseJson = JsonConvert.DeserializeObject<Response>(responseData);
return responseJson;
}
/// <summary>
/// Request
/// </summary>
public class Request
{
/// <summary>
/// Title
/// </summary>
[JsonProperty(PropertyName = "title")]
public string Title { get; set; }
/// <summary>
/// Description
/// </summary>
[JsonProperty(PropertyName = "description")]
public string Description { get; set; }
/// <summary>
/// Content
/// </summary>
[JsonProperty(PropertyName = "content")]
public string Content { get; set; }
/// <summary>
/// URL
/// </summary>
[JsonProperty(PropertyName = "url")]
public string URL { get; set; }
/// <summary>
/// Channel
/// </summary>
[JsonProperty(PropertyName = "channel")]
public string Channel { get; set; }
/// <summary>
/// Token
/// </summary>
[JsonProperty(PropertyName = "token")]
public string Token { get; set; }
}
/// <summary>
/// Response
/// </summary>
public class Response
{
/// <summary>
/// Success
/// </summary>
[JsonProperty(PropertyName = "success")]
public bool Success { get; set; }
/// <summary>
/// Message
/// </summary>
[JsonProperty(PropertyName = "message")]
public string Message { get; set; }
}
}
}
Node.js 示例
const axios = require('axios');
const querystring = require('querystring');
const MESSAGE_PUSHER_SERVER = 'https://msgpusher.com'
const MESSAGE_PUSHER_USERNAME = 'test'
const MESSAGE_PUSHER_TOKEN = '666'
async function send_message(title, description, content) {
try {
const postData = querystring.stringify({
title: title,
desp: description,
content: content,
token: MESSAGE_PUSHER_TOKEN,
})
const response = await axios.post(`${MESSAGE_PUSHER_SERVER}/push/${MESSAGE_PUSHER_USERNAME}`, postData, {
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
},
})
if (response.data.success) {
return response.data
}
} catch (error) {
if (error.response) {
return error.response.data
} else {
throw error
}
}
}
send_message('标题', '描述', '**Markdown 内容**')
.then((response) => {
if (response.success) {
console.log('推送成功:', response)
} else {
console.log('推送失败:', response)
}
}, (error) => {
console.log(error.message);
})
欢迎 PR 添加更多语言的示例。