func loggingInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
    start := time.Now()
    log.Printf("Received request: %s", info.FullMethod)
    
    // 调用实际的处理函数
    resp, err := handler(ctx, req)
    
    log.Printf("Finished request: %s, duration: %v, error: %v", info.FullMethod, time.Since(start), err)
    return resp, err
}

server := grpc.NewServer(grpc.UnaryInterceptor(loggingInterceptor))
pb.RegisterYourServiceServer(server, &yourService{})

func authInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
    ctx = metadata.AppendToOutgoingContext(ctx, "authorization", "Bearer your-jwt-token")
    return invoker(ctx, method, req, reply, cc, opts...)
}

conn, err := grpc.Dial("localhost:50051", grpc.WithUnaryInterceptor(authInterceptor), grpc.WithInsecure())
if err != nil {
    log.Fatal(err)
}

import "github.com/grpc-ecosystem/go-grpc-middleware"

interceptors := []grpc.UnaryServerInterceptor{
    loggingInterceptor,
    recoveryInterceptor, // 恢复panic
    validationInterceptor, // 参数校验
}

combined := grpc_middleware.ChainUnaryServer(interceptors...)
server := grpc.NewServer(grpc.UnaryInterceptor(combined))