MqService.php 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: Bear
  5. * Date: 2018/11/29
  6. * Time: 下午5:42
  7. */
  8. namespace app\main\service;
  9. use app\common\library\Rabbitmq;
  10. use think\Config;
  11. use app\main\model\object\DotObject;
  12. use think\Log;
  13. class MqService extends BaseService
  14. {
  15. /**
  16. * @var MqService
  17. */
  18. protected static $self = NULL;
  19. /**
  20. * @var Rabbitmq
  21. */
  22. protected $mq = null;
  23. /**
  24. * @return MqService
  25. */
  26. public static function instance()
  27. {
  28. if (self::$self == NULL) {
  29. self::$self = new self();
  30. }
  31. return self::$self;
  32. }
  33. /**
  34. * @return Rabbitmq
  35. */
  36. public function getDotMqInstance()
  37. {
  38. if (!$this->mq) {
  39. $this->mq = new Rabbitmq(Config::get('rabbitmq-dot'));
  40. }
  41. return $this->mq;
  42. }
  43. /**
  44. * @param DotObject $dotObject array
  45. * @return \app\main\model\object\ReturnObject
  46. */
  47. public function sendMessage(DotObject $dotObject)
  48. {
  49. try {
  50. $userdotservice = UserdotService::instance();
  51. $userdotservice->handleTask($dotObject);
  52. } catch (\Exception $e) {
  53. return $this->getExceptionReturn($e);
  54. }
  55. }
  56. }