first commit

2024-09-27 01:32:49 +08:00
commit 28ebe05a64
7399 changed files with 1174529 additions and 0 deletions
--- a/金壶/ydyd_service/application/http/Swoole.php
+++ b/金壶/ydyd_service/application/http/Swoole.php
@@ -0,0 +1,114 @@
+<?php
+namespace app\http;
+use app\facade\RedisCache;
+use app\http\service\ChatCloseService;
+use app\http\service\ChatMessageService;
+use app\http\service\ChatService;
+use app\http\service\MessageQueueService;
+use think\facade\Log;
+use think\swoole\Server;
+class Swoole extends Server
+{
+    protected $serverType = 'socket';
+    protected $port = 9502;
+    protected $sockType = SWOOLE_SOCK_TCP | SWOOLE_SSL;
+    protected $option = [
+        'worker_num'=> 4,
+        'task_worker_num' => 4,
+        'daemonize' => true,
+        'backlog' => 128,
+        'heartbeat_idle_time' => 600,
+        'heartbeat_check_interval' => 60,
+        'ssl_cert_file' => '/usr/local/nginx/conf/cert/jinhu11.pem',
+        'ssl_key_file' => '/usr/local/nginx/conf/cert/jinhu11.key',
+    ];
+
+    public function onOpen($server, $request)
+    {
+        //建立连接时，应将用户信息入缓存，并将客服分配给该用户
+        //Cache::setCliUser($request->fd,['id'=>$request->fd, 'ip'=>$request->server['remote_addr']]);
+        //echo '连接建立';
+        //echo json_encode($request);
+        //Log::info(json_encode($request));
+        //Log::info('读$_COOKIE参数'.json_encode($_COOKIE));
+        //Log::info('读cookie参数'.$request->cookie['PHPSESSID']);
+        //取缓存
+        //Log::info('session原会话信息'.Cache::store('session_store')->get($request->cookie['PHPSESSID']));
+        //$session_data=$this->unserialize_php(Cache::store('session_store')->get($request->cookie['PHPSESSID']));
+        //读取user_id
+        //如果不存在user_id，则为游客，随机分配在线客服
+        //如果存在user_id，则查询专属客服，若专属客服不在线，则随机分配在线客服
+        //Log::info('session自解码会话信息'.json_encode();
+        $chat_deal=new ChatService($server,$request);
+        $chat_deal->onOpen();
+    }
+
+    public function onMessage($server, $frame) {
+        //收到消息，根据用户信息发给指定人
+        $chat_message_deal=new ChatMessageService($server,$frame);
+        $chat_message_deal->deal();
+
+        /*$data = json_decode($frame->data,true);
+        switch ($data['type']) {
+            case 'openService' :
+                $chat_deal=new ChatService($server,$frame->fd,$data);
+                $result=$chat_deal->openService();
+                break;
+            default:
+                $result['message_type']='error';
+                $result['data']=['错误消息类型'];
+        }
+        $server->push($frame->fd,myResult($result['message_type'],['content'=>$result['data']]));*/
+    }
+
+    public function onClose($server, $fd) {
+        //连接关闭，将用户信息从缓存中移除，并存入聊天日志
+        $chat_deal=new ChatCloseService($server,$fd);
+        $chat_deal->onClose();
+    }
+
+    public function onStart($server) {
+        //清空所有缓存
+        $base_keys=['CHAT_USER_FD_MAP','CHAT_USER_FD','CHAT_USER_INFO','CHAT_USER_QUEUE','CHAT_CS_FD_MAP','CHAT_CS_FD','CHAT_CS_INFO','CUSTOMER_ONLINE_QUEUE','CHAT_ADMIN_FD_MAP','CHAT_ADMIN_FD','CHAT_ADMIN_INFO'];
+        $chat_list=RedisCache::keys('CHAT_DATA_*');
+        $offline_chat_list=RedisCache::keys('OFFLINE_CHAT_DATA_*');
+        RedisCache::batch_del(array_merge($base_keys,$chat_list,$offline_chat_list));
+
+        Log::info('主进程清除缓存结束');
+
+        //定时刷下数据链接，试试看有没有效果。实际有效果，但有个pipe的问题，因为主进程和工作进程之间实际并没有共享数据库实例，尝试在工作进程中开定时器刷新，以防broken pipe的情况出现
+        /*swoole_timer_tick(1000*600, function () {
+            Db::name('users')->where(['user_id'=>0])->value('user_id');
+        });*/
+    }
+
+    public function onWorkerStart($server,$worker_id) {
+        //定时刷下数据链接，试试看有没有效果。由于8个进程都会刷新，减少刷新频率，30分钟刷一次，试下TP的自动重连机制，暂不刷新
+        /*swoole_timer_tick(1000*1800, function () {
+            Db::name('users')->where(['user_id'=>0])->value('user_id');
+        });*/
+
+        if ($server->taskworker) {
+            Log::info('启动消息队列监听任务进程'.$worker_id);
+            //每个任务进程起一个监听，尝试监听redis，以便实现消息通知
+            while (true) {
+                if (($msgs = RedisCache::brpop('MESSAGE_QUEUE', 5))==null) {
+                    //没有则继续监听
+                    continue;
+                } else {
+                    $message_queue_deal=new MessageQueueService($server,$msgs);
+                    $message_queue_deal->deal();
+                }
+            }
+        } else {
+            Log::info('启动通话处理任务进程'.$worker_id);
+        }
+    }
+
+    public function onTask($server,$task_id,$src_worker_id,$data) {
+        //暂不使用
+    }
+    public function onFinish($server,$task_id,$data) {
+        //暂不使用
+    }
+}