diff --git a/pom.xml b/pom.xml index f75f362..4e7dbf6 100644 --- a/pom.xml +++ b/pom.xml @@ -1,167 +1,173 @@ - - + + - org.sonatype.oss - oss-parent - 7 - - + org.sonatype.oss + oss-parent + 7 + + Java Gearman Service http://code.google.com/p/java-gearman-service/ - Java Gearman Service is an easy-to-use distributed network application framework implementing the gearman protocol used to farm out work to other machines or processes that are better suited to do the work. It allows you to do work in parallel, to load balance processing, and to call functions between languages. It can be used in a variety of applications, from high-availability web sites to the transport of database replication events. In other words, it is the nervous system for how distributed processing communicates. + Java Gearman Service is an easy-to-use distributed network application framework implementing the gearman + protocol used to farm out work to other machines or processes that are better suited to do the work. It allows + you to do work in parallel, to load balance processing, and to call functions between languages. It can be used + in a variety of applications, from high-availability web sites to the transport of database replication events. + In other words, it is the nervous system for how distributed processing communicates. 2010 - gearman - http://www.gearman.org - - - - scm:svn:http://java-gearman-service.googlecode.com/svn/trunk - scm:svn:https://java-gearman-service.googlecode.com/svn/trunk - http://java-gearman-service.googlecode.com/svn/trunk - - - 4.0.0 - org.gearman.jgs - java-gearman-service - 0.7.0-SNAPSHOT - jar - - + gearman + http://www.gearman.org + + + + + + + + + 4.0.0 + org.gearman.jgs + java-gearman-service + 0.7.0-SNAPSHOT + jar + + BSD http://opensource.org/licenses/BSD-2-Clause repo - - - [1.6,2.0) - [4.0,5.0) - - UTF-8 - - License.txt - src/main/resources - lib - - scm:svn:http://java-gearman-service.googlecode.com/svn/trunk - http://java-gearman-service.googlecode.com/svn/trunk - - - - - - src/main/resources - true - - - - - - - - maven-compiler-plugin - 3.0 - - 1.7 - 1.7 - - - - - - org.apache.maven.plugins - maven-javadoc-plugin - 2.9 - - org.gearman.* - - - - javadoc - package - - jar - - - - - - - - org.apache.maven.plugins - maven-source-plugin - 2.2.1 - - - attach-sources - package - - jar - - - - - - - maven-assembly-plugin - 2.4 - - true - - src/main/assembly/zip.xml - - - - - assembly - package - - single - - - - - - - org.apache.maven.plugins - maven-scm-plugin - 1.8.1 - - connection - - - - - - - - - - - org.slf4j - slf4j-api - ${slf4j.version} - compile - - - - junit - junit - ${junit.version} - test - - - - org.slf4j - slf4j-simple - ${slf4j.version} - test - - - - + + + [1.6,2.0) + [4.0,5.0) + + UTF-8 + + License.txt + src/main/resources + lib + + + + + + + + + src/main/resources + true + + + + + + + + maven-compiler-plugin + 3.3 + + 1.8 + 1.8 + + + + + + + + + + + + + + + + + + + + + + + + + org.apache.maven.plugins + maven-source-plugin + 3.0.0 + + + attach-sources + package + + jar + + + + + + + maven-assembly-plugin + 2.5.3 + + true + + src/main/assembly/zip.xml + + + + + assembly + package + + single + + + + + + + + + + + + + + + + + + + + + + org.slf4j + slf4j-api + ${slf4j.version} + compile + + + + junit + junit + ${junit.version} + test + + + + org.slf4j + slf4j-simple + ${slf4j.version} + test + + + + + \ No newline at end of file diff --git a/src/test/java/org/gearman/test/pseudoserver/DemoClient.java b/src/test/java/org/gearman/test/pseudoserver/DemoClient.java new file mode 100644 index 0000000..a54c59d --- /dev/null +++ b/src/test/java/org/gearman/test/pseudoserver/DemoClient.java @@ -0,0 +1,28 @@ +package org.gearman.test.pseudoserver; + +import org.gearman.GearmanServer; +import org.gearman.impl.GearmanImpl; +import org.gearman.impl.client.ClientImpl; +import org.gearman.impl.server.remote.GearmanServerRemote; + +import java.io.IOException; +import java.net.InetSocketAddress; + +/** + * Created by yangjunming on 6/25/16. + */ +public class DemoClient { + + public static void main(String[] args) throws IOException, InterruptedException { + GearmanImpl gearmanImpl = new GearmanImpl(); + GearmanServer gearmanServer = new GearmanServerRemote(gearmanImpl, new InetSocketAddress("localhost", 4730)); + ClientImpl client = new ClientImpl(gearmanImpl); + client.addServer(gearmanServer); + + //异步方式派发任务 + client.submitBackgroundJob("demoTask", "jimmy".getBytes()); + + //同步方式派发任务 + client.submitJob("anotherTask", "mike".getBytes()); + } +} diff --git a/src/test/java/org/gearman/test/pseudoserver/DemoWorker.java b/src/test/java/org/gearman/test/pseudoserver/DemoWorker.java new file mode 100644 index 0000000..c5f0e5e --- /dev/null +++ b/src/test/java/org/gearman/test/pseudoserver/DemoWorker.java @@ -0,0 +1,39 @@ +package org.gearman.test.pseudoserver; + +import org.gearman.GearmanServer; +import org.gearman.GearmanWorker; +import org.gearman.impl.GearmanImpl; +import org.gearman.impl.server.remote.GearmanServerRemote; +import org.gearman.impl.worker.GearmanWorkerImpl; + +import java.io.IOException; +import java.net.InetSocketAddress; + +/** + * Created by yangjunming on 6/25/16. + */ +public class DemoWorker { + + public static void main(String[] args) throws IOException, InterruptedException { + GearmanImpl gearmanImpl = new GearmanImpl(); + GearmanWorker worker = new GearmanWorkerImpl(gearmanImpl); + GearmanServer gearmanServer = new GearmanServerRemote(gearmanImpl, new InetSocketAddress("localhost", 4730)); + worker.addServer(gearmanServer); + + worker.addFunction("demoTask", (function, data, callback) -> { + String param = new String(data, "utf-8"); + System.out.println("demoTask => param：" + param); + return ("demoTask => hello," + param).getBytes(); + }); + + worker.addFunction("anotherTask", (function, data, callback) -> { + String param = new String(data, "utf-8"); + System.out.println("anotherTask => param：" + param); + return ("anotherTask => hello," + param).getBytes(); + }); + + while (true) { + Thread.sleep(100); + } + } +}