PHP7.0에서 메시지 큐를 개발하는 방법은 무엇입니까?

인터넷 기술의 지속적인 발전과 발전에 따라 기술의 효율성과 안정성을 확보하기 위해 다양한 기술적 수단이 끊임없이 제안되고 적용되고 있습니다. 그 중 메시지 큐(이하 MQ) 기술은 현재 가장 널리 사용되고 널리 사용되는 기술적 수단이다. MQ는 시스템의 서로 다른 모듈 간의 비동기 통신 문제를 해결하여 애플리케이션 간의 느슨한 결합과 더 나은 확장성을 구현하는 것을 목표로 합니다. 이 기사에서는 PHP7.0에서 메시지 큐를 개발하는 방법을 소개합니다.

1. MQ 기본

1. 메시지 큐 개념

MQ는 메시지 전달 또는 비동기 처리 기술입니다. 메시지 대기열을 사용하면 발신자와 수신자 간의 느슨하게 연결된 통신이 가능해지며 애플리케이션 간의 상호 연결성과 유지 관리성이 향상됩니다. MQ는 타사 미들웨어를 사용하여 생산자를 통해 메시지를 대기열로 보내고, 소비자는 대기열에서 메시지를 추출하여 소비합니다. MQ는 분산 시스템, 동시성 시스템 및 데이터 백로그 시나리오에서 사용할 수 있습니다.

2. 메시지 대기열 유형

MQ에는 여러 유형이 포함됩니다.

P2P: 지점 간 통신. 생산자는 메시지를 대기열로 보내고 소비자는 이를 수신하여 메시지 전달의 신뢰성을 보장합니다. .

Pub/Sub: 게시-구독 모델. 생산자는 주제에 메시지를 게시하고 구독자는 주제의 메시지를 구독하고 소비하므로 메시지 전달의 탄력성과 확장성을 얻을 수 있습니다.

3. MQ 구성 요소

MQ는 주로 다음 구성 요소로 구성됩니다.

Message: 메시지의 기본 단위

Producer: 메시지 생성자

Consumer: 메시지 소비자

Queue: 메시지 저장 영역

Exchange: 메시지 라우팅

Binding: 메시지 바인딩 관계

2. PHP7.0에서 MQ 개발 방법

1. RabbitMQ 설치

RabbitMQ는 P2P 및 Pub/Sub 모드를 지원할 수 있는 널리 사용되는 MQ 구현입니다. .다양한 프로그래밍 언어로 개발을 지원하며 사용이 매우 쉽습니다. PHP7.0에서 RabbitMQ를 사용하려면 PHP-AMQP 확장을 설치해야 합니다. 단계는 다음과 같습니다.

(1) RabbitMQ를 다운로드하고 압축을 해제합니다. 공식 웹사이트 주소는 다음과 같습니다. http://www.rabbitmq.com/

(2) Erlang 설치: RabbitMQ는 Erlang 언어를 기반으로 개발되었으며, 먼저 Erlang 환경을 설치하십시오.

(3) RabbitMQ 서버 시작:

$ sudo Rabbitmq-server

(4) PHP-AMQP 확장 설치:

$ pecl install amqp

설치가 완료된 후 추가 php.ini 파일에 다음 구성 항목이 있습니다. 측면에서는 amqp 확장 및 작성기를 설치한 다음 amqp 패키지를 설치해야 합니다.

(1) amqp 패키지 설치

$ 작곡가 필요 php-amqplib/php-amqplib

(2) 생산자 코드

다음은 대기열에 메시지를 보내기 위한 PHP 생산자 코드입니다.

먼저 인스턴스화가 필요합니다. 클라이언트는 다음과 같습니다:

$connection = new AMQPConnection();

$connection->setHost('localhost');

$connection->setPort('5672');

$connection-> setLogin(' guest');

$connection->setPassword('guest');

$connection->connect();

메시지 전송 구현:

$exchange = 'test-exchange';
$ queue = ' test-queue';
$message = 'Hello World';

try {

$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName($exchange);
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declareExchange();
$queue = new AMQPQueue($channel);
$queue->setName($queue);
$queue->setFlags(AMQP_DURABLE);
$queue->declareQueue();
$queue->bind($exchange->getName(), $queue->getName());
$exchange->publish($message, $queue->getName());

}

catch (AMQPException $e) {

var_dump($e);

}
$connection->disconnect();

위 코드는 , create 큐 테스트-큐와 교환기 테스트-교환을 거쳐 큐와 교환기를 바인딩한 후 메시지를 보냅니다.

(3) 소비자 코드

다음은 대기열의 메시지를 소비하기 위한 소비자 코드입니다.

먼저 다음과 같이 클라이언트를 인스턴스화합니다.

$connection = new AMQPConnection();

$connection ->setHost( 'localhost');

$connection->setPort('5672');

$connection->setLogin('guest');

$connection->setPassword('guest');

$connection-> connect();

메시지 소비 구현:

$exchange = 'test-exchange';
$queue = 'test-queue';
try {

$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName($exchange);
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declareExchange();
$queue = new AMQPQueue($channel);
$queue->setName($queue);
$queue->setFlags(AMQP_DURABLE);
$queue->declareQueue();
$queue->bind($exchange->getName(), $queue->getName());
$queue->consume(function(AMQPEnvelope $message, AMQPQueue $queue) {
    echo $message->getBody();
    $queue->ack($message->getDeliveryTag());
});

}

catch(AMQPException $e ) {

var_dump($e);

}
$connection->disconnect();

위 코드에서는 queue test-queue와 exchanger test-exchange가 생성된 후 queue와 exchanger가 바인딩된 후 Consumer가 메시지를 가져옵니다. 대기열을 복사하여 콘솔에 인쇄하고 $queue->ack() 메서드를 통해 메시지가 소비되는지 확인합니다.

3. 요약

이 글에서는 PHP7.0에서 MQ를 개발하는 방법을 소개합니다. 먼저 RabbitMQ 및 PHP-AMQP 확장을 설치해야 합니다. 두 번째로 작곡가를 설치하고 amqp 패키지를 설치해야 합니다. 마지막으로 메시지 전송 및 소비를 구현하는 코드를 작성해야 합니다. MQ 기술의 출현은 인터넷 애플리케이션에 보다 편리하고 효율적인 메시지 전달 방법을 제공합니다. 특히 동시성이 높은 시나리오와 분산 시스템에서 MQ는 없어서는 안 될 부분입니다. 이 기사를 연구함으로써 독자들이 PHP7.0에서 MQ 개발의 구체적인 단계와 구현 방법을 이해하고 자신의 비즈니스 애플리케이션에서 MQ 기술을 시험해 볼 수 있는 참고 자료를 제공할 수 있기를 바랍니다.

위 내용은 PHP7.0에서 메시지 큐를 개발하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!