同步

Author: Yurunsoft

example/Consumer/AConsumer.php

@@ -1,8 +1,9 @@
 <?php
-namespace ImiApp\Consumer;
 
-use Imi\Log\Log;
+namespace QueueApp\Consumer;
+
 use Imi\Bean\Annotation\Bean;
+use Imi\Log\Log;
 use Imi\Queue\Contract\IMessage;
 use Imi\Queue\Driver\IQueueDriver;
 use Imi\Queue\Service\BaseQueueConsumer;
@@ -13,16 +14,16 @@
 class AConsumer extends BaseQueueConsumer
 {
     /**
-     * 处理消费
-     * 
-     * @param \Imi\Queue\Contract\IMessage $message
+     * 处理消费.
+     *
+     * @param \Imi\Queue\Contract\IMessage   $message
      * @param \Imi\Queue\Driver\IQueueDriver $queue
+     *
      * @return void
      */
     protected function consume(IMessage $message, IQueueDriver $queue)
     {
         Log::info(sprintf('[%s]%s:%s', $queue->getName(), $message->getMessageId(), $message->getMessage()));
         $queue->success($message);
     }
-
 }

example/Consumer/BConsumer.php

@@ -1,8 +1,9 @@
 <?php
-namespace ImiApp\Consumer;
 
-use Imi\Log\Log;
+namespace QueueApp\Consumer;
+
 use Imi\Bean\Annotation\Bean;
+use Imi\Log\Log;
 use Imi\Queue\Contract\IMessage;
 use Imi\Queue\Driver\IQueueDriver;
 use Imi\Queue\Service\BaseQueueConsumer;
@@ -13,16 +14,16 @@
 class BConsumer extends BaseQueueConsumer
 {
     /**
-     * 处理消费
-     * 
-     * @param \Imi\Queue\Contract\IMessage $message
+     * 处理消费.
+     *
+     * @param \Imi\Queue\Contract\IMessage   $message
      * @param \Imi\Queue\Driver\IQueueDriver $queue
+     *
      * @return void
      */
     protected function consume(IMessage $message, IQueueDriver $queue)
     {
         Log::info(sprintf('[%s]%s:%s', $queue->getName(), $message->getMessageId(), $message->getMessage()));
         $queue->success($message);
     }
-
 }

example/Listener/WorkerStartListener.php

@@ -1,11 +1,11 @@
 <?php
-namespace ImiApp\Listener;
 
-use Swoole\Timer;
-use Imi\Event\EventParam;
-use Imi\Event\IEventListener;
+namespace QueueApp\Listener;
+
 use Imi\Aop\Annotation\Inject;
 use Imi\Bean\Annotation\Listener;
+use Imi\Event\EventParam;
+use Imi\Event\IEventListener;
 use Imi\Queue\Model\Message;
 use Swoole\Coroutine;
 
@@ -22,32 +22,33 @@ class WorkerStartListener implements IEventListener
     protected $imiQueue;
 
     /**
-     * 事件处理方法
+     * 事件处理方法.
+     *
      * @param EventParam $e
+     *
      * @return void
      */
     public function handle(EventParam $e)
     {
         // 每 1 秒投递进 test1 队列
-        Coroutine::create(function(){
-            while(true)
+        Coroutine::create(function () {
+            while (true)
             {
-                $message = new Message;
-                $message->setMessage(time());
+                $message = new Message();
+                $message->setMessage((string) time());
                 $this->imiQueue->getQueue('test1')->push($message);
                 sleep(1);
             }
         });
         // 每 3 秒投递进 test2 队列
-        Coroutine::create(function(){
-            while(true)
+        Coroutine::create(function () {
+            while (true)
             {
-                $message = new Message;
-                $message->setMessage(time());
+                $message = new Message();
+                $message->setMessage((string) time());
                 $this->imiQueue->getQueue('test2')->push($message);
                 sleep(3);
             }
         });
     }
-
-}
+}

example/bin/imi

@@ -1,10 +1,8 @@
 #!/usr/bin/env php
 <?php
-$vendor = dirname(__DIR__, 2) . '/vendor/';
-$loader = require_once $vendor . 'autoload.php';
-
-\Imi\App::setLoader($loader);
+require_once dirname(__DIR__, 2) . '/vendor/' . 'autoload.php';
+require_once dirname(__DIR__, 5) . '/vendor/' . 'autoload.php';
 
 \Imi\App::setDebug(true);
 
-require $vendor . 'bin/imi';
+require dirname(\Imi\Util\Imi::getNamespacePath('Imi')) . '/bin/imi';

src/Annotation/InjectQueue.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace Imi\Queue\Annotation;
 
 use Imi\Aop\Annotation\Inject;
@@ -7,6 +8,7 @@
 
 /**
  * 注入队列对象
+ *
  * @Annotation
  * @Target({"PROPERTY", "ANNOTATION"})
  * @Parser("Imi\Aop\Parser\AopParser")
@@ -22,7 +24,7 @@ public function getRealValue()
     {
         /** @var \Imi\Queue\Service\QueueService $imiQueue */
         $imiQueue = App::getBean('imiQueue');
+
         return $imiQueue->getQueue($this->name);
     }
-
 }