Setting up PHP 5 + Gearman + Java on Ubuntu Linux 9.10 (Karmic)

Bellow are stops to setup a running Gearman based job server which can be used to have various work-distribution clusters especially creating an interoperability between your web layer (esp PHP5) and backing business layer (esp. in Java).

Steps:
Prepare Gearman job server

You may decide to get the source and compile or use Ubunut’s PPA repositories to get them pre-built. I go with the second and added this repository ( deb
http://ppa.launchpad.net/gearman-developers/ppa/ubuntu karmic main ) to my /etc/apt/source.list .

Install Job Server

sudo aptitude update
sudo aptitude install gearman-job-server

Prepare PHP environment

sudo aptitude install uuid-dev php5-dev
sudo pecl install channel://pecl.php.net/gearman-0.7.0

And also add extension=gearman.so to both:

• /etc/php5/apache2/php.ini
• /etc/php5/cli/php.ini

Check Gearman PHP extension
Get phpinfo() and see if gearman exists there

<?php
phpinfo();
?>

Setup Java/Gearman Binding

Get the project from https://launchpad.net/gearman-java

Startup Gearmand

sudo /etc/init.d/gearman-job-server start

Sample Java based Worker

import org.gearman.client.*;
import org.gearman.common.GearmanJobServerConnection;
import org.gearman.common.GearmanNIOJobServerConnection;
import org.gearman.worker.AbstractGearmanFunction;
import org.gearman.worker.GearmanWorker;
import org.gearman.worker.GearmanWorkerImpl;

public class SampleGearmanWorker {

  public static void main(String[] args) {
    final GearmanJobServerConnection connection = new
    GearmanNIOJobServerConnection("localhost", 4730);

    GearmanWorker worker = new GearmanWorkerImpl();
    worker.addServer(connection);

    worker.registerFunction(SampleFunction.class);

    worker.work();
  }

  private static final byte[] EMPTY_BYTES = new byte[]{};

  public static class SampleFunction extends AbstractGearmanFunction {

  @Override
  public String getName() {
    return "test";
  }

  @Override
  public GearmanJobResult executeFunction() {
    final byte[] hello = "hello ".getBytes();
    final byte[] name = (byte[]) this.data;
    final byte[] resp = new byte[hello.length + name.length];

    System.arraycopy(hello, 0, resp, 0, hello.length);
    System.arraycopy(name, 0, resp, hello.length, name.length);

    final GearmanJobResult jr = new
        GearmanJobResultImpl(this.jobHandle, true, resp, EMPTY_BYTES, EMPTY_BYTES, 0, 0);

    return jr;
    }
  }
}

Sample PHP Client

<?php
$client= new GearmanClient();
$client->addServer();
print $client->do("test", "amin")."\n";
?>

Run the example

run Java code and also php gearman-client.php. It will print “hello amin” :)

Hope it helps!