在Docker容器中利用LibreOffice与PHP进行文件转换的微服务实践

version: '3.8'

services:
  nginx:
    image: nginx:alpine
    ports:
      - "80:80"
    volumes:
      - ./:/var/www/html
      - ./docker/nginx/default.conf:/etc/nginx/conf.d/default.conf
    depends_on:
      - php-fpm
      - converter # 确保 Nginx 也知道 converter 服务
    networks:
      - app-network

  php-fpm:
    image: php:8.1-fpm-alpine
    volumes:
      - ./:/var/www/html
    networks:
      - app-network

  converter:
    image: sgbj/versed:latest # 使用 sgbj/versed 镜像
    environment:
      - PORT=3000 # 默认端口，可以根据需要修改
    ports:
      - "3000:3000" # 如果需要从宿主机访问，可以暴露端口，否则内部通信不需要
    networks:
      - app-network

networks:
  app-network:
    driver: bridge

<?php

return [
    'converter_endpoint' => env('CONVERTER_ENDPOINT', 'http://converter:3000/convert')
];

CONVERTER_ENDPOINT=http://converter:3000/convert

<?php

namespace App\Http\Controllers;

use Illuminate\Http\Request;
use Illuminate\Support\Facades\Http;
use Illuminate\Http\Client\ConnectionException;
use Exception;

class FileConversionController extends Controller
{
    /**
     * 将指定文件通过微服务转换为目标格式。
     *
     * @param string $sourceFilePath 待转换文件的完整路径
     * @param string $outputFormat 目标格式 (例如 'txt', 'pdf')
     * @param string $outputDirPath 转换后文件保存的目录
     * @return string 转换后文件的路径，或原始文件路径（如果转换失败）
     */
    public function convertFile(string $sourceFilePath, string $outputFormat, string $outputDirPath): string
    {
        // 确保源文件存在
        if (!file_exists($sourceFilePath)) {
            throw new Exception("源文件不存在: " . $sourceFilePath);
        }

        // 构建输出文件路径
        $fileName = pathinfo($sourceFilePath, PATHINFO_FILENAME);
        $outputFileName = $fileName . '.' . $outputFormat;
        $destinationFilePath = rtrim($outputDirPath, '/') . '/' . $outputFileName;

        // 打开源文件句柄
        $fileHandler = fopen($sourceFilePath, 'r');
        if (!$fileHandler) {
            throw new Exception("无法打开源文件进行读取: " . $sourceFilePath);
        }

        try {
            $response = Http::attach(
                'file', // 表单字段名，通常是 'file'
                $fileHandler,
                basename($sourceFilePath) // 原始文件名
            )
            ->timeout(60) // 设置请求超时时间，根据文件大小和转换复杂性调整
            ->withOptions([
                'sink' => $destinationFilePath // 直接将响应流保存到文件
            ])
            ->post(config('custom.converter_endpoint'), [
                'format' => $outputFormat, // 目标格式，例如 'pdf', 'txt'
            ]);

            if ($response->successful()) {
                // 转换成功
                // 可选：删除原始文件，如果它是临时文件
                // unlink($sourceFilePath);
                return $destinationFilePath;
            } else {
                // 转换服务返回错误
                logger()->error("文件转换失败：", [
                    'status' => $response->status(),
                    'body' => $response->body(),
                    'source_file' => $sourceFilePath,
                    'output_format' => $outputFormat
                ]);
                return $sourceFilePath; // 返回原始文件路径
            }
        } catch (ConnectionException $e) {
            // 转换服务不可用或网络连接错误
            logger()->error("连接文件转换服务失败: " . $e->getMessage(), [
                'endpoint' => config('custom.converter_endpoint'),
                'source_file' => $sourceFilePath
            ]);
            return $sourceFilePath; // 返回原始文件路径
        } finally {
            // 确保关闭文件句柄
            fclose($fileHandler);
        }
    }

    /**
     * 示例：处理上传的DOCX文件并转换为PDF
     *
     * @param Request $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function processUpload(Request $request)
    {
        $request->validate([
            'document' => 'required|file|mimes:doc,docx|max:10240', // 10MB限制
        ]);

        $uploadedFile = $request->file('document');
        $tempPath = $uploadedFile->storeAs('temp_uploads', $uploadedFile->getClientOriginalName()); // 保存到临时目录

        $sourceFilePath = storage_path('app/' . $tempPath);
        $outputDirPath = public_path('converted_files'); // 转换后文件保存的公共目录

        // 确保输出目录存在
        if (!file_exists($outputDirPath)) {
            mkdir($outputDirPath, 0777, true);
        }

        try {
            $convertedFilePath = $this->convertFile($sourceFilePath, 'pdf', $outputDirPath);

            // 如果转换成功，可以删除临时上传的文件
            if ($convertedFilePath !== $sourceFilePath) {
                unlink($sourceFilePath);
                return response()->json(['message' => '文件转换成功', 'path' => asset(str_replace(public_path(), '', $convertedFilePath))]);
            } else {
                return response()->json(['message' => '文件转换失败，返回原始文件', 'path' => asset(str_replace(public_path(), '', $sourceFilePath))], 500);
            }
        } catch (Exception $e) {
            logger()->error("文件处理异常: " . $e->getMessage());
            // 清理临时文件
            if (file_exists($sourceFilePath)) {
                unlink($sourceFilePath);
            }
            return response()->json(['message' => '文件处理过程中发生错误', 'error' => $e->getMessage()], 500);
        }
    }
}

// 假设 $sourceFilePath 是你的 .doc 或 .docx 文件路径
// 假设 $outputDirPath 是你希望保存 .txt 文件的目录
$txtFilePath = $this->convertFile($sourceFilePath, 'txt', $outputDirPath);

if ($txtFilePath !== $sourceFilePath) {
    // 文件成功转换为 TXT
    $wordCount = str_word_count(file_get_contents($txtFilePath));
    // 可以在这里删除临时生成的 .txt 文件
    // unlink($txtFilePath);
    echo "文件字数: " . $wordCount;
} else {
    echo "文件转换失败，无法统计字数。";
}