标题：*
140 字

TAG标签：（用空格隔开）
30 字

恢复历史版本：

HTML转MD HTML转MD2

由于原生PHP不支持多线程模型，所以Swoole更多时候使用多进程模型，因此代码相对更加简洁，减少了各种线程锁的阻塞和同步，但同时也带来了新的问题：数据共享。由于多线程可以直接共享进程的内存，进程之间数据的相互同步则需要依赖于共享内存。原生PHP进程之间是不能相互通信的，在<code>swoole_process</code>中则是可以的，Swoole中进程之间的通信是通过管道<code>pipe</code>来传递的。多进程、多线程之间的数据共享则是通过内存<code>memory</code>来实现的。<code>swoole_table</code>共享内存表是一个基于共享内存和锁实现的超高性能并发数据结构，用于解决多进程或多线程数据共享和同步加锁问题，它不消耗服务器 IO，纯内存操作，性能十分强悍。优势共享内存表可以直接操作系统的内存，性能强悍，单线程每秒可读写200万每次，主要用于进程间的数据通信。共享内存表应用代码无需加锁，内置行锁自旋锁，所有操作都是多进程或多线程安全，用户层完全不需要考虑数据同步问题。共享内存表支持多进程，内存表可以用于多进程之间共享数据。共享内存表使用行锁而非全局锁，仅当两个进程在同一CPU时间并发读取同一条数据时才会发生抢锁。共享内存表不受PHP的<code>memory_limit</code>最大内存的控制适用场景：用于解决多进程或多线程数据共享和同步加锁问题，进程结束后共享内存表会自动释放。<pre class="line-numbers language-php">&lt;?phpuse&nbsp;Swoole\Table;//创建共享内存表对象$size&nbsp;=&nbsp;1024;//2的n次方$table&nbsp;=&nbsp;new&nbsp;swoole_table($size);//共享内存表添加字段$table-&gt;column(&quot;id&quot;,&nbsp;Table::TYPE_INT,&nbsp;11);$table-&gt;column(&quot;name&quot;,&nbsp;Table::TYPE_STRING,&nbsp;20);$table-&gt;column(&quot;money&quot;,&nbsp;Table::TYPE_FLOAT,&nbsp;10);$table-&gt;create();//共享内存表添加行$table-&gt;set(&quot;alice&quot;,&nbsp;[&quot;id&quot;=&gt;1,&nbsp;&quot;name&quot;=&gt;&quot;alice&quot;,&nbsp;&quot;money&quot;=&gt;100.5]);//使用数组方式添加行$table[&quot;ben&quot;]&nbsp;=[&quot;id&quot;=&gt;2,&nbsp;&quot;name&quot;=&gt;&quot;ben&quot;,&nbsp;&quot;money&quot;=&gt;200.1];//获取行返回数组$val&nbsp;=&nbsp;$table-&gt;get(&quot;alice&quot;);var_dump($val);//获取行返回对象$val&nbsp;=&nbsp;$table[&quot;ben&quot;];var_dump($val);//共享内存表内字段值增加$table-&gt;incr(&quot;alice&quot;,&nbsp;&quot;money&quot;,&nbsp;100);var_dump($table[&quot;alice&quot;]);//共享内存表中字段值减少$table-&gt;decr(&quot;ben&quot;,&nbsp;&quot;money&quot;,&nbsp;50);var_dump($table[&quot;ben&quot;]);echo&nbsp;json_encode($table).PHP_EOL;</pre><h2>创建对象<code>construct</code></h2>创建共享内存表，实测$size*2才不报分配内存不足<pre class="line-numbers language-php">function&nbsp;Table-&gt;__construct(int&nbsp;$size,&nbsp;float&nbsp;$conflict_propertion&nbsp;=&nbsp;0.2);</pre>共享内存表实际上是一个开链法实现的哈希表，内存是由哈希键<code>Key</code>与具体数据组成的数组，如果哈希冲突即不同的键值对一个同一个哈希，那么就会从内存池<code>pool</code>中分配出一个元素作为数组元素的链表尾。内存表占用的内存总数 = ( 结构体长度 + 哈希键长度<code>64byte</code> + 行尺寸<code>$size</code> ) * 预留作为哈希冲突的百分比 * 列尺寸参数1：<code>int $size</code><code>$size</code>表示创建共享内存表时设置的最大行数，必须是2的次方，如果不是底层会自动调整为接近的一个数字，若小于1024则默认为1024，即1024为最小值。若机器内存不足内存表会创建失败。共享内存表底层是建立在共享内存之上的哈希表<code>HashTable</code>（数据结构），最大行数<code>$size</code>决定了哈希表的总行数。由于内存表是在共享内存之上，所以无法动态扩容，因此<code>$size</code>必须在创建前提前设置好。参数2：<code>float $conflict_propertion</code> 哈希冲突率如果哈希冲突超过最大比例，共享内存表将不再允许添加新的行元素。共享内存表能存储的总数据行数取决于数据的哈希键冲突率，默认如果冲突率超过20%，预留的哈希<code>hash</code>冲突内存块容量不足，会报<code>Unable to allocate memory</code>无法分配内存的错误，并返回<code>false</code>表示存储失败。<pre class="line-numbers language-php">&lt;?phpuse&nbsp;Swoole\Table;//创建共享内存表对象$size&nbsp;=&nbsp;1024;//2的n次方$table&nbsp;=&nbsp;new&nbsp;swoole_table($size);$table-&gt;column(&quot;data&quot;,&nbsp;Table::TYPE_STRING,&nbsp;1);$table-&gt;create();echo&nbsp;json_encode($table).PHP_EOL;//&nbsp;{&quot;size&quot;:1024,&quot;memorySize&quot;:117548}</pre><h2>添加列数据<code>column</code></h2>共享内存表新增一列<pre class="line-numbers language-php">bool&nbsp;Table-&gt;column(string&nbsp;$name,&nbsp;int&nbsp;$type,&nbsp;int&nbsp;$size&nbsp;=&nbsp;0)swoole_table-&gt;column(string&nbsp;$name,&nbsp;int&nbsp;$type,&nbsp;int&nbsp;$size&nbsp;=&nbsp;0)</pre>参数列表<ul class=" list-paddingleft-2"><li><code>string $name</code> 表示字段的名称</li><li><code>int $type</code> 表示字段类型，可支持3种类型分别是<code>Table::TYPE_INT</code>、<code>Table::TYPE_FLOAT</code>、<code>Table::TYPE_STRING</code>。</li><li><code>int $size</code> 表示字符串字段的最大长度单位字节，字符串类型<code>Table::TYPE_STRING</code>的字段必须指定<code>$size</code>。</li></ul>字段类型<ul class=" list-paddingleft-2"><li><code>Table::TYPE_INT</code> 整型默认4字节，可设置1、2、4、8共四种长度。</li><li><code>Table::TYPE_STRING</code> 字符型必须指定，设置的字符串不得超过设置值。</li><li><code>Table::TYPE_FLOAT</code> 浮点型，占用8字节的内存。</li></ul>整型溢出由于Swoole底层使用有符号整型，如果传入的数值超过溢出边界就可能会发生溢出。整数类型安全值的范围<ul class=" list-paddingleft-2"><li><code>int8</code> 1byte -127 ~127</li><li><code>int16</code> 2byte &nbsp;-32767~327767</li><li><code>int32</code> 4byte &nbsp;-2147483647 ~ 2147483647</li><li><code>int64</code> 8byte 不会溢出</li></ul>内存对齐从Swoole4.3版本开始，底层对内存长度做了对齐处理。字符串长度必须是8的整数倍，如果长度为18字节会自动对其到24字节。注意非<code>x86</code>环境则内存对齐。<h2>创建共享内存表<code>create</code></h2>当定义好表的结构后执行<code>create</code>会向操作系统申请内存并创建共享内存表。需要注意的是，调用<code>create</code>创建之前不能使用<code>set</code>、<code>get</code>等数据读写操作，调用<code>create</code>创建之后不能使用<code>column</code>添加新字段。如果 系统内存不足则会申请失败此时<code>create</code>将返回<code>false</code>，若申请成功<code>create</code>将会返回<code>true</code>。<code>Table</code>使用共享内存来保存数据，在创建子进程之前，务必要执行<code>create</code>执行创建。服务器中使用共享内存表执行<code>create</code>创建操作必须在服务器执行<code>start</code>启动方法之前。当使用<code>create</code>方法创建共享内存表后，可以读取<code>$table-&gt;memorySize</code>属性来获取实际占用的内存尺寸，单位为字节。<pre class="line-numbers language-jsx">function&nbsp;Table-&gt;create():bool</pre><h2>设置行数据<code>set</code></h2>共享内存表使用键值对的方式存取数据<pre class="line-numbers language-php">Table-&gt;set(string&nbsp;$key,&nbsp;array&nbsp;$value):bool</pre>参数列表参数1：<code>string $key</code>设置行数据对应的键名，相同的键名对应同一行数据，如果<code>set</code>设置了同一个键名则会覆盖上一次的数据。参数2：<code>array $value</code>设置行数据对应的键值，必须是一个数组，必须与字段定义的名称<code>$name</code>完全相同。返回值设置成功返回<code>true</code>，设置失败返回<code>false</code>，失败的原因可能是由于哈希冲突过多导致动态空间无法分配内存，可以调大构造方法的<code>$conflict_propertion</code>参数。如果传入字符串的长度超过列定义的最大尺寸，底层会自动截断。<h2>获取行数据<code>get</code></h2>获取单行数据<pre class="line-numbers language-php">array&nbsp;Table-&gt;get(string&nbsp;$key,&nbsp;string&nbsp;$field&nbsp;=&nbsp;null)</pre>参数列表中<code>string $key</code>表示查询数据行的键名，必须为字符串类型。如果带查询的键名不存在，则<code>get</code>方法将会返回<code>false</code>。若成功则返回的结果为数组类型。<h2>检查键名是否存在<code>exist</code></h2><code>exist</code>方法用于检查共享内存表中是否存在某个键名<code>key</code>，若存在则返回<code>true</code>，否则返回<code>false</code>。<pre class="line-numbers language-php">bool&nbsp;swoole_table-&gt;exists(string&nbsp;$key)</pre><h2>条目数量<code>count</code></h2><code>count</code>方法用于获取共享内存表<code>table</code>中存在的条目数量<pre class="line-numbers language-php">int&nbsp;function&nbsp;Table-&gt;count()</pre><h2>删除键值对<code>del</code></h2><pre class="line-numbers language-php">bool&nbsp;Table-&gt;del(string&nbsp;$keyy)</pre><code>del</code>方法用于删除共享内存表<code>$table</code>中指定键名<code>$key</code>的行，如果键名<code>$key</code>对应的是数据不存在则返回<code>false</code>，否则成功返回<code>true</code>。此处需要注意的是键名<code>$key</code>是非二进制安全的，所以必须为字符串类型，因此不得传入二进制数据。<h3>原子递增<code>incr</code></h3><pre class="line-numbers language-php">function&nbsp;Table-&gt;incr(string&nbsp;$key,&nbsp;string&nbsp;$column.&nbsp;mixed&nbsp;$incrby&nbsp;=&nbsp;1):&nbsp;int</pre><ul class=" list-paddingleft-2"><li><code>incr</code>表示原子递增操作，参数<code>string $key</code>表示指定数据的键名，如果键名对应的行不存在则默认值为0。</li><li><code>int column</code> 表示指定的列表即字段名，仅支持浮点型和整型字段。</li><li><code>int $incrby</code>表示则增量默认为1，若列为整型则增量必须为整型，如果列为浮点型则增量必须为浮点型。</li></ul>返回最终的结果数值<h2>原子自减<code>decr</code></h2><pre class="line-numbers language-php">function&nbsp;Table-&gt;decr(string&nbsp;$key,&nbsp;string&nbsp;$column,&nbsp;mixed&nbsp;$decrby&nbsp;=&nbsp;1)&nbsp;int&nbsp;|&nbsp;bool</pre>参数列表<ul class=" list-paddingleft-2"><li><code>string $key</code>表示指定数据的键名，如果键名对应的行不存在，底层会首先将该行数据初始化为0。</li><li><code>string $column</code>表示指定的列名，仅支持浮点型和整型字段。</li><li><code>mixed $decrby</code>表示减量默认为1，如果列为整型则减量必须也为整型，同样如果列为浮点型则减量也必须为浮点型。</li></ul>返回值将返回最终的结果数值，数值为0时递减会变成负数。实例：创建swoole_table用于进程间数据共享<pre class="line-numbers language-php">&lt;?phpclass&nbsp;Server{
&nbsp;&nbsp;&nbsp;&nbsp;private&nbsp;$server;
&nbsp;&nbsp;&nbsp;&nbsp;public&nbsp;function&nbsp;__construct($host=&quot;0.0.0.0&quot;,&nbsp;$port&nbsp;=&nbsp;9501,&nbsp;$size&nbsp;=&nbsp;1024)
&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//创建swoole_table用于进程间数据共享
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$table&nbsp;=&nbsp;new&nbsp;swoole_table($size);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$table-&gt;column(&quot;fd&quot;,&nbsp;swoole_table::TYPE_INT);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$table-&gt;column(&quot;uid&quot;,&nbsp;swoole_table::TYPE_INT);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$table-&gt;column(&quot;type&quot;,&nbsp;swoole_table::TYPE_STRING,&nbsp;256);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$table-&gt;column(&quot;data&quot;,&nbsp;swoole_table::TYPE_STRING,&nbsp;256);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$table-&gt;create();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//创建WebServer服务器对象
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$this-&gt;server&nbsp;=&nbsp;new&nbsp;swoole_websocket_server($host,&nbsp;$port);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$this-&gt;server-&gt;table&nbsp;=&nbsp;$table;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//注册事件回调函数
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$this-&gt;server-&gt;on(&quot;handShake&quot;,&nbsp;[$this,&nbsp;&quot;onHandShake&quot;]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$this-&gt;server-&gt;on(&quot;workerStart&quot;,&nbsp;[$this,&nbsp;&quot;onWorkerStart&quot;]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$this-&gt;server-&gt;on(&quot;open&quot;,&nbsp;[$this,&nbsp;&quot;onOpen&quot;]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$this-&gt;server-&gt;on(&quot;message&quot;,&nbsp;[$this,&nbsp;&quot;onMessage&quot;]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$this-&gt;server-&gt;on(&quot;close&quot;,&nbsp;[$this,&nbsp;&quot;onClose&quot;]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//开启服务器
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;$this-&gt;server-&gt;start();
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;public&nbsp;function&nbsp;onHandShake($server)
&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;echo&nbsp;&quot;[handshake]&quot;.PHP_EOL;
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;public&nbsp;function&nbsp;onWorkerStart($server)
&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;echo&nbsp;&quot;[workerstart]&quot;.PHP_EOL;
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;public&nbsp;function&nbsp;onOpen($server)
&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;echo&nbsp;&quot;[open]&quot;.PHP_EOL;
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;public&nbsp;function&nbsp;onMessage($server)
&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;echo&nbsp;&quot;[message]&quot;.PHP_EOL;
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;public&nbsp;function&nbsp;onClose($message)
&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;echo&nbsp;&quot;[close]&quot;.PHP_EOL;
&nbsp;&nbsp;&nbsp;&nbsp;}}$server&nbsp;=&nbsp;new&nbsp;Server();</pre> 作者：JunChow520 链接：https://www.jianshu.com/p/1dae870407bc 来源：简书 著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。