commit 03cfbd929e04e4eba42d1872542128aee351b8c8
Author: Mr·x <as2252258@163.com>
Date:   Tue Aug 31 17:46:05 2021 +0800

    e

diff --git a/README.md b/README.md
new file mode 100644
index 0000000..e69de29
diff --git a/composer.json b/composer.json
new file mode 100644
index 0000000..2898998
--- /dev/null
+++ b/composer.json
@@ -0,0 +1,25 @@
+{
+  "name": "game-worker/kiri-rpc",
+  "description": "kiri-rpc",
+  "authors": [
+    {
+      "name": "XiangLin",
+      "email": "as2252258@163.com"
+    }
+  ],
+  "license": "MIT",
+  "require": {
+    "php": ">=8.0",
+    "ext-json": "*",
+    "ext-rdkafka": "*",
+    "psr/event-dispatcher": "^1.0"
+  },
+  "autoload": {
+    "psr-4": {
+      "Kiri\\Rpc\\": "src/"
+     }
+  },
+  "require-dev": {
+    "kwn/php-rdkafka-stubs": "^2.0"
+  }
+}
diff --git a/src/Service.php b/src/Service.php
new file mode 100644
index 0000000..cfc4269
--- /dev/null
+++ b/src/Service.php
@@ -0,0 +1,83 @@
+<?php
+
+namespace Kiri\Rpc;
+
+use Server\SInterface\OnClose;
+use Server\SInterface\OnConnect;
+use Server\SInterface\OnPacket;
+use Server\SInterface\OnReceive;
+use Server\SInterface\OnRequest;
+use Swoole\Http\Request;
+use Swoole\Http\Response;
+use Swoole\Server;
+
+
+/**
+ *
+ */
+class Service implements OnClose, OnConnect, OnReceive, OnPacket, OnRequest
+{
+
+
+	/**
+	 * @param Server $server
+	 * @param int $fd
+	 */
+	public function onClose(Server $server, int $fd): void
+	{
+		// TODO: Implement onClose() method.
+	}
+
+
+	/**
+	 * @param Server $server
+	 * @param int $fd
+	 */
+	public function onDisconnect(Server $server, int $fd): void
+	{
+		// TODO: Implement onDisconnect() method.
+	}
+
+
+	/**
+	 * @param Server $server
+	 * @param int $fd
+	 */
+	public function onConnect(Server $server, int $fd): void
+	{
+		// TODO: Implement onConnect() method.
+	}
+
+
+	/**
+	 * @param Server|\Server\Abstracts\Server $server
+	 * @param string $data
+	 * @param array $clientInfo
+	 */
+	public function onPacket(Server|\Server\Abstracts\Server $server, string $data, array $clientInfo): void
+	{
+		// TODO: Implement onPacket() method.
+	}
+
+
+	/**
+	 * @param Server $server
+	 * @param int $fd
+	 * @param int $reactor_id
+	 * @param string $data
+	 */
+	public function onReceive(Server $server, int $fd, int $reactor_id, string $data): void
+	{
+		// TODO: Implement onReceive() method.
+	}
+
+
+	/**
+	 * @param Request $request
+	 * @param Response $response
+	 */
+	public function onRequest(Request $request, Response $response): void
+	{
+		// TODO: Implement onRequest() method.
+	}
+}