go-zero中api服务使用全局拦截器
1.中间件
package apiserver
import (
"context"
"fmt"
"go-weixin/app/usercenter/userrpc/pb/proto/usercenter"
"go-weixin/app/usercenter/userrpc/userrpcclient"
"go-weixin/common/ctxdata"
"net/http"
分类目录归档:backend
package apiserver
import (
"context"
"fmt"
"go-weixin/app/usercenter/userrpc/pb/proto/usercenter"
"go-weixin/app/usercenter/userrpc/userrpcclient"
"go-weixin/common/ctxdata"
"net/http"
func (u UserDomain) UserGetPower(id int64) ([]model.PowerModel, error) {
// 先获取redids缓存
powerListStr, err := u.cache.Get(fmt.Sprintf("user_powers_%d", id))
powerList := make([]model.PowerModel, 0)
if err != nil {
return nil, err
}
if powerL[Unit]
Description=gofastdfs service
Wants=network.target
[Service]
PIDFile=/home/gofastdfs/conf/app.pid
WorkingDirectory=/root/go-fastdfs/src/go-fastdfs-master
Environment="GO_FASTDFS_DIR=/root/go-fastdfs/src/go-fastdfs-master"
ExecStart=/root/go-fastdfs/src/
package main
import (
"context"
"fmt"
"log"
"os"
"os/signal"
"syscall"
"time"
"github.com/segmentio/kafka-go"
)
var (
topic = "user_click&quomain.go
package main
import (
"flag"
"fmt"
"grpc-common/ucenter/types/login"
"grpc-common/ucenter/types/register"
"ucenter/internal/config"
"ucenter/internal/middleware"
import subprocess
def cmd_file_merge(save_url, m3u8_name, save_mp4_name):
process = subprocess.Popen(f"ffmpeg -f concat -safe 0 -i {m3u8_name} -c copy -y {save_mp4_name}", cwd=save_url)
out, err = process.communicate()
print("执行ts文件合并成mp4..\n"◼ -i 设定输入流 ◼ -f 设定输出格式(format) ◼ -ss 开始时间 ◼ -t 时间长度
◼ -aframes 设置要输出的音频帧数 ◼ -b:a 音频码率 ◼ -ar 设定采样率 ◼ -ac 设定声音的Channel数 ◼ -acodec 设定声音编解码器,如果用copy表示原始编解码数据必须被拷贝。 ◼ -an 不处理音频 ◼ -af 音频过滤器
◼ -vframes 设置要输出的视频帧数 ◼ -b 设定视频码率 ◼ -b:v 视频码率 ◼ -r 设定帧速率 ◼ -s 设定画面的宽与高 ◼ -vn 不处理视频 ◼ -as
ffmpeg -i out.mp4 -vbsf h264_mp4toannexb -vcodec copy -acodec aac -strict 2 -g 150 -hls_time 20 -hls_list_size 0 -start_number 0 -f hls -y out.m3u8
ffmpeg -i out.mp4 -bsf:v h264_mp4toannexb -vcodec copy -acodec aac -strict 2 -g 150 -hls_time 20 -hls_list_size 0 -start_number 0