Spring项目中Java Gearman-Client连接任务服务器卡住无异常问题

问题原因 #

GearmanNIOJobServerConnection基于Java NIO实现，需要启动独立的IO线程处理连接建立、数据读写等事件。你当前的代码没有启动这个IO线程，导致addJobServer方法一直阻塞等待连接状态变为已建立，从而出现无响应的“卡住”现象。当Gearman服务器关闭时，连接失败的状态会被同步检测到，因此能正常抛出异常。

解决步骤 #

• 启动NIO连接的IO线程：创建GearmanNIOJobServerConnection后，必须调用start()方法启动其内部的IO事件循环，否则连接永远无法建立。
• 初始化逻辑移至Spring Bean生命周期：不要在控制器请求线程中重复创建Gearman客户端和连接，应该将其作为单例Bean初始化，避免资源浪费和线程阻塞问题。
• 添加连接超时控制：推荐使用waitForConnection设置超时时间，防止无限阻塞。

修正后的代码示例 #

Spring配置类初始化Gearman客户端 #

import org.gearman.GearmanClient;
import org.gearman.GearmanClientImpl;
import org.gearman.GearmanJobServerConnection;
import org.gearman.GearmanNIOJobServerConnection;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.concurrent.TimeUnit;

@Configuration
public class GearmanConfig {

    @Bean(destroyMethod = "shutdown")
    public GearmanClient gearmanClient() {
        GearmanJobServerConnection connection = new GearmanNIOJobServerConnection("localhost", 4730);
        // 启动NIO连接的IO线程
        connection.start();
        
        // 等待连接建立，设置5秒超时
        try {
            if (!connection.waitForConnection(5, TimeUnit.SECONDS)) {
                connection.shutdown();
                throw new RuntimeException("无法连接到Gearman任务服务器");
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            connection.shutdown();
            throw new RuntimeException("连接Gearman服务器被中断", e);
        }
        
        GearmanClient client = new GearmanClientImpl();
        client.addJobServer(connection);
        return client;
    }
}

控制器中注入使用 #

import org.gearman.GearmanClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class GearmanTestController {

    @Autowired
    private GearmanClient gearmanClient;

    @GetMapping("/test-gearman")
    public String testGearmanConnection() {
        // 在这里编写Gearman任务执行逻辑
        return "Gearman连接正常";
    }
}

额外注意事项 #

• 应用关闭时，Spring会自动调用Bean的destroyMethod执行shutdown()，释放Gearman连接和线程资源。
• 不要在请求线程中重复创建GearmanClient实例，单例复用是最优实践。
• 如果使用同步连接（GearmanTraditionalJobServerConnection），则不需要手动启动线程，但NIO连接性能更优，适合高并发场景。

内容的提问来源于stack exchange，提问作者M364M4N cro