Royal 发布的文章 - 桑帅东的博客

2023-07-07

FFI扩展调用C的so动态库什么是FFI？此扩展允许在纯PHP中加载共享库（.DLL或.so），调用C函数以及访问C数据结构，而无需深入了解Zend扩展API。这个扩展需要安装 libffi libffi-devel库，编译安装步骤具体步骤就不说了（phpize、configure、make、make install四部曲），另外此扩展要求PHP版本必须是(PHP 7 >= 7.4.0, PHP 8)，安装完通过php -m就可以看到下面的模块。FFI的API都有哪些？FFI::addr— 创建指向C数据的非托管指针FFI::alignof— 获取对齐方式FFI::arrayType— 动态构造一个新的C数组类型FFI::cast— 执行C类型转换FFI::cdef— 创建一个新的FFI对象FFI::free— 释放非托管数据结构FFI::isNull— 检查FFI \ CData是否为空指针FFI::load— 从C头文件加载C声明FFI::memcmp— 比较内存区域FFI::memcpy— 将一个存储区复制到另一个FFI::memset— 填充内存区域FFI::new— 创建一个C数据结构FFI::scope— 在预加载期间使用解析的C声明实例化FFI对象FFI::sizeof— 获取C数据或类型的大小FFI::string— 从内存区域创建一个PHP字符串FFI::type— 从C声明创建FFI \ CType对象FFI::typeof— 获取FFI \ CData的FFI \ CTypeFFI怎么用？直接上例子，下面就是通过一个实例来说明FFI怎么调用C的动态库函数。首先通过FFI::cdef创建一个FFI对象，定义我们动态库中的常量、结构体、函数、以及通过地址加载我们的动态库。 define('ECCref_MAX_BITS', 512); define('ECCref_MAX_LEN', (ECCref_MAX_BITS + 7) / 8); define("SGD_SM3", 0x00000001); $this->ffi = FFI::cdef(<<<EOH // 定义结构体 typedef struct ECCrefPublicKey_st{ unsigned int bits; unsigned char *x; unsigned char *y; } ECCrefPublicKey; // 定义打开设备函数 int SDF_OpenDevice(void **phDeviceHandle); // 定义创建会话句柄函数 int SDF_OpenSession(void *hDeviceHandle, void **phSessionHandle); // 定义生成随机数函数 int SDF_GenerateRandom(void *hSessionHandle, unsigned int uiLength, unsigned char *pucRandom); // 定义杂凑运算初始化函数 int SDF_HashInit(void *hSessionHandle, unsigned int uiAlgID, ECCrefPublicKey *pucPublicKey, unsigned char *pucID, unsigned int uiIDLength); EOH , '/home/sangshuaidong/sdk/libcsapi.so');#加载动态库然后，我们在方法中进行调用c函数。public function openDevice() { $deviceHandlePtr = FFI::new("void*[1]"); $result = $this->ffi->SDF_OpenDevice($deviceHandlePtr); if ($result == 0) { $this->deviceHandle = $deviceHandlePtr[0]; return true; } else { return false; } } public function openSession() { $sessionHandlePtr = FFI::new("void*[1]"); $result = $this->ffi->SDF_OpenSession($this->deviceHandle, FFI::addr($sessionHandlePtr)); if ($result == 0) { $this->sessionHandle = $sessionHandlePtr[0]; return true; } else { return false; } } // 获取16位随机数 public function generateRandom($length) { $randomBuffer = FFI::new("unsigned char[$length]"); $result = $this->ffi->SDF_GenerateRandom($this->sessionHandle, $length, $randomBuffer); if ($result == 0) { $randomHex = bin2hex(FFI::string($randomBuffer, $length)); return $randomHex; } else { return false; } } // hash杂凑运算初始化 public function hashInit($algID = "SGD_SM3", $length = 0) { $result = 0; if ($algID === 'SGD_SM3') { $publicKey =$this->ffi->new("ECCrefPublicKey"); $publicKey->bits = 0; $unsignedCharType = FFI::arrayType(FFI::type('unsigned char'), [ECCref_MAX_LEN]); $publicKey->x = FFI::cast('unsigned char*', FFI::new($unsignedCharType)); $publicKey->y = FFI::cast('unsigned char*', FFI::new($unsignedCharType)); $result = $this->ffi->SDF_HashInit( $this->sessionHandle, SGD_SM3, FFI::addr($publicKey), FFI::addr(FFI::new("unsigned char")), $length ); } else { // 其他算法的处理，根据实际情况进行设置 } if ($result == 0) { return true; } else { return false; } } 最后，我们通过执行可执行程序可以看到成功输出！

2023年07月07日
239 阅读
0 评论
1 点赞

2023-06-21

线上服务怎么部署golang应用程序编译我们的golang项目并生成可执行程序(二进制文件)go build main.go我们需要考虑将应用程序作为系统服务运行。为此，我们需要编写一个systemd服务文件。在/etc/systemd/system/目录中，使用vim或nano等编辑器创建一个新文件，文件名称为devcloud.service，当然您也可以为其取其他的名称在devcloud.service文件中，添加以下内容：[Unit] Description=devcloud After=syslog.target After=network.target [Service] # Modify these two values and uncomment them if you have # repos with lots of files and get an HTTP error 500 because # of that ### #LimitMEMLOCK=infinity LimitNOFILE=100000 LimitNPROC=100000 Type=forking # 如果要启动的命令是一个daemon进程, 这里的值设置为forking User=root Group=root # WorkingDirectory，程序的运行目录 WorkingDirectory=/home/goproject/src # ExecStart，程序的启动命令，必须为绝对路径，若WorkingDirectory有变动，ExecStart路径对应也要变动 ExecStart=/home/goproject/src/main Restart=always ExecStop=/bin/kill -9 $(pidof main) # Some distributions may not support these hardening directives. If you cannot start the service due # to an unknown option, comment out the ones not supported by your version of systemd. # ProtectSystem=full # PrivateDevices=yes # PrivateTmp=yes # NoNewPrivileges=true [Install] WantedBy=multi-user.target注释：常见的Type类型有以下这些：在Systemd配置文件中，常见的Type选项的取值有以下几种类型：simple：默认类型。当该服务以Type=simple启动时，Systemd会认为启动命令是简单的，不会进一步检查进程的状态。Systemd仅仅启动命令，并认为启动完成后服务已经就绪。forking：当服务启动时，Systemd会认为启动命令会派生（fork）出一个子进程，并认为服务在子进程就绪后才完成启动。此类型的服务会在主进程退出后仍然继续运行。oneshot：适用于只执行一次任务的服务。当服务启动时，Systemd会等待命令执行完成，然后认为服务已经完成启动。dbus：适用于通过DBus启动的服务。notify：适用于服务启动完成后向Systemd发送通知的情况。idle：适用于服务在空闲状态时启动的情况。exec：仅执行一次命令，不会认为服务在命令执行完成后就绪。以上是常见的Type选项的取值类型。根据您的需求和服务的特性，选择适合的Type选项来定义服务的启动类型。保存文件后，使用以下命令启动新的系统服务并将其添加到自动启动中：systemctl start devcloud systemctl enable devcloud执行以上命令后，您的服务应该已经在Linux服务器上成功运行并自动启动，可以使用以下命令查看服务启动状态：systemctl status devcloud重启/停止服务systemctl restart devcloud systemctl stop devcloud

2023年06月21日
204 阅读
0 评论
0 点赞

2022-10-11

2022年10月11日
196 阅读
0 评论
0 点赞

2022-09-15

记一次线上socket_read的坑先来看下问题：测试的时候发现三个执行体只有php的执行体所在的板卡CPU占用率居高不下，java和python的则正常，由于服务正在被多人测试，导致登录界面加载很慢，验证码刷新不出等问题。排查：通过排查发现，左括号输出日志，报了8080超时，8080端口为php的服务，而此时拟态大屏在频繁发送数据请求，而右括号服务没有正常响应，导致执行体的客户端一直在等待接收数据，因为执行体作为TCP客户端跟右括号建立通信时需要接收指定的长度才会断开连接，但是使用了socket_set_nonblock非阻塞模式设置，所以如果没有接收到数据就会跳出外层for循环，一直持续4分钟的时间，这样就会导致cpu资源被for循环全部占用。我们先来看下有问题的代码：我们知道socket_read,socket_recv,socket_accept均为默认的阻塞模式，什么是阻塞模式，就是当程序运行到此函数时，会一直读取服务端发来的数据，直到接收满2048个字节的（最大设置65535）长度才会继续往下运行，否则就停留在此处，交由操作系统和底层网络接管程序，一直监听，直到超时为止，所以问题就来了，在这个代码中由于把read设置成了socket_set_nonblock($socket);非阻塞模式，也就是说当运行到这里时，由于右括号服务已经挂了所以不会发送数据，自然而然也不会读到数据，由于又没有超时设置，所以很快就往下继续运行了，跳出本次循环，继续下次循环，这个时间是很短暂的，也就是说当有括号不发数据时，执行体一直在运行for循环，自然而然cpu就飙上去了，直到手动设置的超时4分钟结束才中断连接，也就是这4分钟内其他服务都不能访问！！虽然CPU升高是由于右括号的服务异常，继而导致php执行体服务运行不正常最终导致的，但是我们还是要尽量避免由于别的模块或者服务不正常导致自己的服务出问题继而瘫痪整个系统的情况。要尽量把异常缩小在可控范围内。解决知道问题所在了，那么就很好解决了，可以通过以下方式进行修改：设置为非阻塞模式，并增加读取数据超时时间设置；socket_set_option($socket,SOL_SOCKET,SO_RCVTIMEO,array("sec"=>10, "usec"=>0 ) );记住：一定要注释掉非阻塞改为阻塞，不然即使加了阻塞超时设置也不会生效，因为本质是非阻塞，非阻塞就是死循环。增加多路复用阻塞：假如我一定要用非阻塞设置该怎么办呢？办法很多，那就是在read前面加多路复用阻塞：参数描述read 指向一组等待可读性检查的套接字write 指向一组等待可写性检查的套接字except 指向一组等待错误检查的套接字tv_sec 用来设置select()的等待时间，秒tv_usec两者组成了用来设置select()的等待时间，微妙这种方式也很好理解，就相当于在read非阻塞模式前加了阻塞判断，select来监听read的数据。当读取出来数据为空时会一直读，直到10s为止，可以理解为比sleep()更高级点，PHP的socket_select函数也是调用系统的select函数实现的。PHP中socket_select()函数传入的read和write数组是引用传入的，所以每次调用socket_select()后read和write或者except数组中会包含最新的可以使用的资源数组。传入的是要监视的，而调用socket_select后得到的是可以用的。多路是指多个客户端连接socket，复用就是指复用少数几个进程，多路复用本身依然隶属于同步通信方式，只是表现出的结果看起来像异步，这点值得注意．目前多路复用有三种常用的方案，依次是：select，最早的解决方案poll，算是select的升级版epoll，目前的最终解决版，解决c10k问题的功臣使用其他方式其实该问题的本质还是解决死循环过程中CPU过高的问题，只不过我们改为阻塞，就避免了程序死循环过程中被过多占用CPU资源的问题，我们其实可以直接暴利一点使用sleep(),判断当接收不到数据时就sleep来释放资源，不过这种方式过于暴利，会影响性能，你要知道循环一次sleep1毫秒循环10000次就是10s 不可想象！！总结通过以上总结，我们在使用socket通信时，如果对并发量要求不高，尽量使用阻塞模式，由于我们使用了负载均衡，所以对单机并发量不是特别要求。阻塞的socket函数在调用send，recv，connect，accept等函数时，如果特定的条件不满足，就会阻塞其调用线程直至超时，非阻塞的socket恰恰相反。非阻塞模式一般用于需要支持高并发多QPS的场景（如服务器程序），但是正如前文所述，这种模式让程序的执行流和控制逻辑变得复杂；相反，阻塞模式逻辑简单，程序结构简单明了，常用于一些特殊场景中。应用场景一：某程序需要临时发送一个文件，文件分段发送，每发送一段，对端都会给予一个响应，该程序可以单独开一个任务线程，在这个任务线程函数里面，使用先send后recv再send再recv的模式，每次send和recv都是阻塞模式的。应用场景二：A端与B端之间的通信只有问答模式，即A端每发送给B端一个请求，B端比定会给A端一个响应，除此之外，B端不会向A端推送任何数据，此时A端就可以采用阻塞模式，在每次send完请求后，都可以直接使用阻塞式的recv函数接收应答包。

2022年09月15日
275 阅读
0 评论
1 点赞

2022-08-12

2022年08月12日
233 阅读
0 评论
0 点赞