Gearman使用示例

最近的一个旧项目重构过程中，使用到了gearman这个开源项目，简单来讲，这是一个类似MQ的异步系统，一边派发任务，一边处理任务(有类似MQ中的消息发送方与接收方)，目前支持java，php等多种语言，缺点是存在单点问题（server的HA官方没有提供方案，需要二次开发）。

官网地址：http://www.gearman.org

下面是java语言的示例：

注：gearman的java客户端实例有好几个版本，不同的版本之间相差巨大，建议使用官方推荐的最新版，地址为https://github.com/gearman/java-service

 

一、spring配置

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
 5 
 6     <bean id="gearmanImpl" class="org.gearman.impl.GearmanImpl"></bean>
 7 
 8     <bean id="gearmanServer" class="org.gearman.impl.server.remote.GearmanServerRemote">
 9         <constructor-arg index="0" ref="gearmanImpl"/>
10         <constructor-arg index="1">
11             <bean class="java.net.InetSocketAddress">
12                 <constructor-arg index="0" value="localhost"/>
13                 <constructor-arg index="1" value="4730"/>
14             </bean>
15         </constructor-arg>
16     </bean>
17 
18     <bean id="gearmanClient" class="org.gearman.impl.client.ClientImpl">
19         <constructor-arg index="0" ref="gearmanImpl"/>
20     </bean>
21 
22     <bean id="gearmanWorker" class="org.gearman.impl.worker.GearmanWorkerImpl">
23         <constructor-arg index="0" ref="gearmanImpl"/>
24     </bean>
25 
26 
27 </beans>

View Code