`
yangfuchao418
  • 浏览: 165863 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

gearman 处理类

阅读更多

import java.util.ArrayList;
import java.util.List;

import org.gearman.client.GearmanJobResult;
import org.gearman.client.GearmanJobResultImpl;
import org.gearman.util.ByteUtils;
import org.gearman.worker.AbstractGearmanFunction;
//真正的业务逻辑
public class ReverseFunction extends AbstractGearmanFunction {
    
    public GearmanJobResult executeFunction() {
    	GearmanJobResult gjr=null;
      //  StringBuffer sb = new StringBuffer(ByteUtils.fromUTF8Bytes((byte[]) this.data));
        for(int i=0;i<10;i++){
        	 StringBuffer sb = new StringBuffer(ByteUtils.fromUTF8Bytes((byte[]) this.data));
        	
         gjr = new GearmanJobResultImpl(this.jobHandle,
                true, sb.reverse().toString().getBytes(),
                new byte[0], new byte[0], 0, 0);
         System.out.println("--"+sb.toString()+"--");
         try {
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
        }
        return gjr;
    }
}
class show extends Thread{
	  public void run(){
		  ClientTest test=new ClientTest("192.168.101.143", 4730);
             System.out.println(test.reverse("hello"));
  }
 }
分享到:
评论

相关推荐

    Gearman C# API和示例

    Gearman 是一个分布式任务队列系统,它允许应用程序在多台服务器之间分发工作负载,以提高处理效率和可扩展性。在这个“Gearman C# API和示例”项目中,我们将探讨如何使用C#语言与Gearman进行交互,以及如何在...

    gearman下载gearman下载

    Gearman是一款开源的分布式任务队列系统,它允许应用程序在多台机器上分发工作负载,从而实现异步处理和负载均衡。这个系统的重点在于解耦任务的发起者和执行者,使得系统能够灵活地扩展并提高处理能力。在本讨论中...

    Laravel开发-php-gearman

    在 Laravel 中集成 Gearman,你可以创建自定义的 Job 类来封装需要异步处理的任务,然后使用 Gearman 客户端将这些任务发送到 Gearman 服务器。下面是一些关键步骤: #### 安装扩展 首先,你需要通过 Composer ...

    Laravel开发-laravel-gearman-rpc

    通过集成 Laravel 和 Gearman,你可以创建一个强大的异步任务处理系统,提高应用程序的响应速度和并发处理能力。理解 Gearman 的工作原理和如何在 Laravel 中使用它,对于构建高可用性和可扩展性的 Web 应用至关重要...

    Gearman java APIs和一个小Demo

    `MyTaskHandler` 是一个实现了 `Runnable` 接口的类,用于处理实际任务逻辑: ```java class MyTaskHandler implements Runnable { @Override public void run() { byte[] taskData = worker.getData(); String...

    gearman-java.zip_BadMagicException_Gearman java

    在"gearman-java.zip_BadMagicException_Gearman java"这个问题中,`BadMagicException`是一个Java异常,通常在处理字节码或类文件时出现。这个异常表明尝试加载的.class文件的魔数(magic number)不正确,魔数是每...

    net_gearman-master.zip

    在PHP的世界里,Gearman是一个强大的分布式任务处理框架,它允许开发者将任务分发到多台服务器上执行,从而实现负载均衡和异步处理。本文将深入探讨net_gearman-master.zip,这是一个专为PHP设计的Gearman客户端插件...

    PHP并发多进程处理利器Gearman使用介绍

    Gearman 可以用于各种异步处理任务,例如图片处理、订单处理、批量邮件发送、数据处理、日志聚集等需要大量 CPU 或内存的场景。它还能支持分布式和并行处理,以及定时任务,如增量更新和数据复制。此外,它还能够...

    gearman开源任务调度系统.pdf

    9. 通告 Client:“我安排别人处理你的请求了,耐心等待吧”。 10. Worker 辛苦工作一段时间后,向 Server 通告“干完了”。 11. Server 将结果反馈给用户。 Gearman 的任务分类和执行方式: 1. 任务分类: * 按...

    pecl-gearman:libgearmanPHP包装器

    扩展提供了如`GearmanClient`、`GearmanWorker`、`GearmanJob`等类,分别用于客户端任务提交、工作者任务处理以及任务状态的封装。 - `GearmanClient`类:用于创建客户端实例,连接Gearman服务器,提交任务,监控...

    gearman-distributed-job:熟悉Gearman的分布式工作

    在Java环境中,我们可以利用Gearman库来构建分布式工作流程,实现任务的异步处理和并行执行。 首先,我们需要了解Gearman的基本概念。它主要由三部分组成:Job Server、Workers和Clients。Job Server是核心,负责...

    Laravel开发-jobserver

    Gearman 是一个通用的工作队列系统,它为分布式环境提供了灵活的异步任务处理能力。Jobserver 是 Gearman 的一个实现,它允许开发者将任务分发到一组工作服务器上,以执行耗时或复杂的操作,而不会阻塞主线程。 **2...

    python基于json文件实现的gearman任务自动重启代码实例

    在Python编程中, Gearman 是一个分布式任务队列系统,常用于处理异步任务和负载均衡。本实例探讨了如何利用Python和JSON文件来实现 Gearman 任务的自动重启功能,确保任务在失败时能够得到恢复。以下是相关知识点的...

    Laravel开发-frontqueue

    "Laravel开发-frontqueue"的主题就是关于如何在Laravel项目中集成Gearman Jobserver来实现异步任务处理。 Gearman Jobserver是一个开源的分布式任务队列,它可以将任务分发到多个工作节点,从而提高系统的并行处理...

    php的队列实现和使用包装, 默认自带支持 高 high 中 norm 低 low 三个级别的队列操作

    4. Gearman:分布式任务队列,PHP有gearman扩展支持。 5. PHP内置扩展:如sysvmsg、sysvsem、msg_queue等,用于进程间通信。 三、队列的级别与使用 在PHP的队列实现中,提到的“高”、“中”、“低”三个级别,通常...

    基于PHP的咖啡蜘蛛池php版源码.zip

    8. **任务调度**:对于大型项目,可能需要使用任务调度工具(如Gearman、RabbitMQ或Celery)来管理爬虫任务,控制爬取频率,避免对目标网站造成过大压力。 9. **错误处理与日志记录**:良好的错误处理和日志记录...

    利用elasticsearch和redis检索和存储十亿信息.doc

    为了处理高并发的请求,HipChat采用了**Gearman** 作为队列服务,以及**Curler** 作为worker服务器,实现任务的异步处理。系统配置和部署则借助开源工具Chef和Fabric进行自动化管理,Capistrano用于代码部署,而...

    关于PHP实现异步操作的研究

    因此,异步操作成为了处理这类问题的一种有效手段。异步操作允许耗时操作在后台执行,而主进程可以继续响应其他请求,从而避免了阻塞和超时的问题。 首先,PHP实现异步操作的需求,主要源于它在Web页面展示等短暂...

Global site tag (gtag.js) - Google Analytics