import java.util.concurrent.ExecutionException;
import org.gearman.client.GearmanClient;
import org.gearman.client.GearmanClientImpl;
import org.gearman.client.GearmanJob;
import org.gearman.client.GearmanJobImpl;
import org.gearman.client.GearmanJobResult;
import org.gearman.common.GearmanNIOJobServerConnection;
import org.gearman.util.ByteUtils;
class PrintThread extends Thread{
public void run(){
ClientTest test=new ClientTest("192.168.101.143", 4730);
System.out.println(test.reverse("hello"));
}
}
public class ClientTest {
GearmanClient client;
GearmanNIOJobServerConnection con;
public ClientTest(String host, int port) {
con = new GearmanNIOJobServerConnection(host, port);
client = new GearmanClientImpl();
client.addJobServer(con);//添加一个任务
}
public String reverse(String input) {
String function = ReverseFunction.class.getCanonicalName();//调用函数
ReverseFunction rf=new ReverseFunction();
//String reverseValue=rf.reverseValue(input);
byte[] data = ByteUtils.toUTF8Bytes(input);
String value = "";
GearmanJob job = GearmanJobImpl.createJob(function, data, null);
client.submit(job);
try {
GearmanJobResult rs = job.get();
value = ByteUtils.fromUTF8Bytes(rs.getResults());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ExecutionException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return value;
}
public void shutdown()
{
if(null==client){
System.out.println("no client to shutdown");
}
client.shutdown();
}
public static void main(String[] args) throws Exception {
String host="192.168.101.143";
int port =4730;
String input="woyo";
ClientTest clientTest=new ClientTest(host, port);
/* for(int i=0;i<10;i++){
Thread t = new PrintThread();
t.start();
Thread.sleep(1000);
}*/
input=clientTest.reverse(input);
// System.out.println(input);
clientTest.shutdown();
}
}
分享到:
相关推荐
Gearman java API和一个小Demo
gearman-java-0.03,这是一个有关gearman-java-0.03相关的java源代码
gearman java 0.6.6版本 java-gearman-service-0.6.6.jar
java-gearman-service-0.6.6.zip 包,gearman分为3部分,client - server - worker,创建 java 版本的client和worker部分。 其实在gearman中,client和worker的编写不复杂,但是不同厂商提供的API是不大相同的,本...
java实现gearman的job实现的jar包,包括gearman server,client和work客户端API
gearman的java库有两个,一个是gearman service ,一个是gearman java,相比来说service版本更好用一些,并且网上的教程一般是用的这个版本。因此我打好了gearman service的包提供给需要的开发者使用。
java实现gearman的job实现的jar包,包括gearman server,client和work客户端API
gearman下载gearman下载gearman下载gearman下载gearman下载
Gearman中文手册,gearman手册chm,Gearman中文详解,分享gearman技术心得,主要是为了分享技术,所以不要大家的资源分。
Gearman中文手册,gearman手册chm,Gearman中文详解,分享gearman技术心得,主要是为了分享技术,所以不要大家的资源分。
实测可用
实测可用
gearman 文档,gearman 是个集群计算框架,通过对其扩展能够充分利用集群计算
GearMAN讲解及所带来的变革 全面介绍Gearman原理、应用
Gearman环境搭建可能会用到的资料. gearmand-1.1.12.tar.gz libevent-2.0.22-stable.tar.gz libuuid-1.0.3.tar.gz
Laravel开发-php-gearman Gearman作业服务器工人助手
实测可用
实测可用
Gearman 的C#开发API和一个简单自带demo,vs2008.
Laravel开发-laravel-gearman-rpc Laravel/Lumen Gearman RPC。基于https://github.com/mhlavc/gearman