php-beanstalkd消息队列类实例分享

/**

• Reserve a job (with a timeout).
• @param integer $timeout If given specifies number of seconds to wait for
• a job. 0 returns immediately.
• @return array|false false on error otherwise an array holding job id
• and body.
  */
  public function reserve($timeout = null) {
  if (isset($timeout)) {
  $this->_write(sprintf('reserve-with-timeout %d',$timeout));
  } else {
  $this->_write('reserve');
  }
  $status = strtok($this->_read(),' ');

switch ($status) {
  case 'RESERVED':
    return [
      'id' => (integer) strtok(' '),'body' => $this->_read((integer) strtok(' '))
    ];
  case 'DEADLINE_SOON':
  case 'TIMED_OUT':
  default:
    $this->_error($status);
    return false;
}

}

/**

• Removes a job from the server entirely.
• @param integer $id The id of the job.
• @return boolean false on error,true on success.
  */
  public function delete($id) {
  $this->_write(sprintf('delete %d',$id));
  $status = $this->_read();

switch ($status) {
  case 'DELETED':
    return true;
  case 'NOT_FOUND':
  default:
    $this->_error($status);
    return false;
}

}

/**

• Puts a reserved job back into the ready queue.
• @param integer $id The id of the job.
• @param integer $pri Priority to assign to the job.
• @param integer $delay Number of seconds to wait before putting the job in the ready queue.
• @return boolean false on error,true on success.
  */
  public function release($id,$delay) {
  $this->_write(sprintf('release %d %d %d',$id,$delay));
  $status = $this->_read();

switch ($status) {
  case 'RELEASED':
  case 'BURIED':
    return true;
  case 'NOT_FOUND':
  default:
    $this->_error($status);
    return false;
}

}

/**

• Puts a job into the buried state Buried jobs are put into a FIFO
• linked list and will not be touched until a client kicks them.
• @param integer $id The id of the job.
• @param integer $pri New priority to assign to the job.
• @return boolean false on error,true on success.
  */
  public function bury($id,$pri) {
  $this->_write(sprintf('bury %d %d',$pri));
  $status = $this->_read();

switch ($status) {
  case 'BURIED':
    return true;
  case 'NOT_FOUND':
  default:
    $this->_error($status);
    return false;
}

}

/**

• Allows a worker to request more time to work on a job.
• @param integer $id The id of the job.
• @return boolean false on error,true on success.
  */
  public function touch($id) {
  $this->_write(sprintf('touch %d',$id));
  $status = $this->_read();

switch ($status) {
  case 'TOUCHED':
    return true;
  case 'NOT_TOUCHED':
  default:
    $this->_error($status);
    return false;
}

}

/**

• Adds the named tube to the watch list for the current connection.
• @param string $tube Name of tube to watch.
• @return integer|boolean false on error otherwise number of tubes in watch list.
  */
  public function watch($tube) {
  $this->_write(sprintf('watch %s',' ');

switch ($status) {
  case 'WATCHING':
    return (integer) strtok(' ');
  default:
    $this->_error($status);
    return false;
}

}

/**

• Remove the named tube from the watch list.
• @param string $tube Name of tube to ignore.
• @return integer|boolean false on error otherwise number of tubes in watch list.
  */
  public function ignore($tube) {
  $this->_write(sprintf('ignore %s',' ');

switch ($status) {
  case 'WATCHING':
    return (integer) strtok(' ');
  case 'NOT_IGNORED':
  default:
    $this->_error($status);
    return false;
}

}

/ Other Commands /

/**

• Inspect a job by its id.
• @param integer $id The id of the job.
• @return string|boolean false on error otherwise the body of the job.
  */
  public function peek($id) {
  $this->_write(sprintf('peek %d',$id));
  return $this->_peekRead();
  }

/**

• Inspect the next ready job.
• @return string|boolean false on error otherwise the body of the job.
  */
  public function peekReady() {
  $this->_write('peek-ready');
  return $this->_peekRead();
  }

（编辑：云计算网_泰州站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!