Update php client features local

.github/workflows/codespell_check.yaml

@@ -20,6 +20,6 @@ jobs:
       - name: Run CodeSpell
         run: |
           codespell --quiet-level=2 \
-                   --skip "./cpp/third_party,./style/codespell/ignore_words.txt,./.git" \
+                   --skip "./cpp/third_party,./php/vendor,./nodejs/node_modules,./style/codespell/ignore_words.txt,./.git" \
                    --ignore-words ./style/codespell/ignore_words.txt \
                    --exclude-file ./style/codespell/exclude_file.txt \

.github/workflows/php_build.yml

@@ -8,7 +8,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        php-version: ["7.4", "8.0", "8.1"]
+        php-version: ["8.1", "8.2", "8.3"]
         os: [ ubuntu-22.04, macos-11, windows-2022 ]
     steps:
       - name: Checkout
@@ -17,9 +17,32 @@ jobs:
         uses: shivammathur/setup-php@v2
         with:
           php-version: ${{ matrix.php-version }}
+          extensions: grpc, protobuf
       - name: Validate composer.json
         working-directory: ./php
         run: composer validate
       - name: Install Dependencies
         working-directory: ./php
-        run: composer install
+        run: composer install --no-interaction --prefer-dist
+      - name: Run PHPUnit Tests
+        if: runner.os != 'Windows'
+        working-directory: ./php
+        run: vendor/bin/phpunit --testsuite "RocketMQ PHP Test Suite" --no-coverage
+      - name: Run PHPUnit Tests (Windows)
+        if: runner.os == 'Windows'
+        working-directory: ./php
+        shell: bash
+        # Workaround: gRPC C extension may cause non-zero exit during PHP shutdown on
+        # Windows even when all tests pass. Only suppress the exit code when PHPUnit
+        # reports success (OK) but the process exits non-zero due to the gRPC issue.
+        run: |
+          set +e
+          vendor/bin/phpunit --testsuite "RocketMQ PHP Test Suite" --no-coverage > phpunit_output.txt 2>&1
+          exit_code=$?
+          set -e
+          cat phpunit_output.txt
+          if [ "$exit_code" -ne 0 ] && grep -qE 'OK \([0-9]+ tests?' phpunit_output.txt; then
+            echo "::warning::PHPUnit reported success but process exited with code $exit_code - likely gRPC shutdown issue on Windows"
+            exit 0
+          fi
+          exit "$exit_code"

README-CN.md

@@ -19,16 +19,16 @@
 
 | 特性                                             | Java  | C/C++  |  C#   | Golang | Rust | Python | Node.js |  PHP  |
 |------------------------------------------------| :---: |:------:|:-----:|:------:|:----:|:------:|:-------:| :---: |
-| Producer with standard messages                |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Producer with FIFO messages                    |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Producer with timed/delay messages             |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Producer with transactional messages           |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Producer with recalling timed/delay messages   |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Simple consumer                                |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Push consumer with concurrent message listener |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Push consumer with FIFO message listener       |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Push consumer with FIFO consume accelerator    |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Priority Message                               |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
+| Producer with standard messages                |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Producer with FIFO messages                    |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Producer with timed/delay messages             |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Producer with transactional messages           |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Producer with recalling timed/delay messages   |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Simple consumer                                |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Push consumer with concurrent message listener |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Push consumer with FIFO message listener       |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Push consumer with FIFO consume accelerator    |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Priority Message                               |   ✅   |   🚧   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
 
 ## 先决条件和构建
 

README.md

@@ -19,16 +19,16 @@ Provide cloud-native and robust solutions for Java, C++, C#, Golang, Rust and al
 
 | Feature                                        | Java  | C/C++ |  C#   | Golang | Rust  | Python | Node.js |  PHP  |
 | ---------------------------------------------- | :---: | :---: | :---: | :----: | :---: | :----: | :-----: | :---: |
-| Producer with standard messages                |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Producer with FIFO messages                    |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Producer with timed/delay messages             |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Producer with transactional messages           |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Producer with recalling timed/delay messages   |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Simple consumer                                |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Push consumer with concurrent message listener |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Push consumer with FIFO message listener       |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Push consumer with FIFO consume accelerator    |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
-| Priority Message                               |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   🚧   |
+| Producer with standard messages                |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Producer with FIFO messages                    |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Producer with timed/delay messages             |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Producer with transactional messages           |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Producer with recalling timed/delay messages   |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Simple consumer                                |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Push consumer with concurrent message listener |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Push consumer with FIFO message listener       |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Push consumer with FIFO consume accelerator    |   ✅   |   ✅   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
+| Priority Message                               |   ✅   |   🚧   |   ✅   |   ✅    |   ✅   |   ✅    |    ✅    |   ✅   |
 
 ## Prerequisite and Build
 

php/.gitignore

@@ -2,3 +2,6 @@
 src
 vendor
 composer.lock
+coverage
+.phpunit.result.cache
+phpunit.xsd

php/ClientConfiguration.php

@@ -0,0 +1,168 @@
+<?php
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+namespace Apache\Rocketmq;
+
+/**
+ * ClientConfiguration - Immutable configuration value object.
+ * Created exclusively by ClientConfigurationBuilder::build().
+ * Referencing Java ClientConfiguration.java
+ */
+class ClientConfiguration
+{
+    private readonly string $endpoints;
+    private readonly ?SessionCredentials $sessionCredentialsProvider;
+    private readonly int $requestTimeoutMs;
+    private readonly bool $sslEnabled;
+    private readonly string $namespace;
+    private readonly int $maxStartupAttempts;
+    private readonly ?TlsCredentials $tlsCredentials;
+
+    /**
+     * Private constructor - instantiated only via ClientConfiguration::create().
+     *
+     * @param string                     $endpoints                 Target endpoint addresses.
+     * @param SessionCredentials|null    $sessionCredentialsProvider Session credentials provider for authentication.
+     * @param int                        $requestTimeoutMs          RPC request timeout in milliseconds.
+     * @param bool                       $sslEnabled                Whether SSL is enabled.
+     * @param string                     $namespace                 Namespace for the client.
+     * @param int                        $maxStartupAttempts        Maximum number of startup retry attempts.
+     * @param TlsCredentials|null        $tlsCredentials            TLS credentials for secure connections.
+     */
+    private function __construct(
+        string $endpoints,
+        ?SessionCredentials $sessionCredentialsProvider,
+        int $requestTimeoutMs,
+        bool $sslEnabled,
+        string $namespace,
+        int $maxStartupAttempts,
+        ?TlsCredentials $tlsCredentials = null
+    ) {
+        $this->endpoints = $endpoints;
+        $this->sessionCredentialsProvider = $sessionCredentialsProvider;
+        $this->requestTimeoutMs = $requestTimeoutMs;
+        $this->sslEnabled = $sslEnabled;
+        $this->namespace = $namespace;
+        $this->maxStartupAttempts = $maxStartupAttempts;
+        $this->tlsCredentials = $tlsCredentials;
+    }
+
+    /**
+     * Factory method - only callable from ClientConfigurationBuilder.
+     *
+     * @param string                     $endpoints                 Target endpoint addresses.
+     * @param SessionCredentials|null    $sessionCredentialsProvider Session credentials provider for authentication.
+     * @param int                        $requestTimeoutMs          RPC request timeout in milliseconds.
+     * @param bool                       $sslEnabled                Whether SSL is enabled.
+     * @param string                     $namespace                 Namespace for the client.
+     * @param int                        $maxStartupAttempts        Maximum number of startup retry attempts.
+     * @param TlsCredentials|null        $tlsCredentials            TLS credentials for secure connections.
+     * @return ClientConfiguration       New immutable configuration instance.
+     *
+     * @internal
+     */
+    public static function create(
+        string $endpoints,
+        ?SessionCredentials $sessionCredentialsProvider,
+        int $requestTimeoutMs,
+        bool $sslEnabled,
+        string $namespace,
+        int $maxStartupAttempts,
+        ?TlsCredentials $tlsCredentials = null
+    ): ClientConfiguration {
+        return new self(
+            $endpoints,
+            $sessionCredentialsProvider,
+            $requestTimeoutMs,
+            $sslEnabled,
+            $namespace,
+            $maxStartupAttempts,
+            $tlsCredentials
+        );
+    }
+
+    /**
+     * Get the target endpoints address.
+     *
+     * @return string Target endpoint addresses.
+     */
+    public function getEndpoints(): string
+    {
+        return $this->endpoints;
+    }
+
+    /**
+     * Get the session credentials provider.
+     *
+     * @return SessionCredentials|null Session credentials provider, or null if not set.
+     */
+    public function getSessionCredentialsProvider(): ?SessionCredentials
+    {
+        return $this->sessionCredentialsProvider;
+    }
+
+    /**
+     * Get the RPC request timeout in milliseconds.
+     *
+     * @return int RPC request timeout in milliseconds.
+     */
+    public function getRequestTimeoutMs(): int
+    {
+        return $this->requestTimeoutMs;
+    }
+
+    /**
+     * Check whether SSL is enabled.
+     *
+     * @return bool True if SSL is enabled, false otherwise.
+     */
+    public function isSslEnabled(): bool
+    {
+        return $this->sslEnabled;
+    }
+
+    /**
+     * Get the namespace.
+     *
+     * @return string Namespace for the client.
+     */
+    public function getNamespace(): string
+    {
+        return $this->namespace;
+    }
+
+    /**
+     * Get the maximum number of startup retry attempts.
+     *
+     * @return int Maximum number of startup retry attempts.
+     */
+    public function getMaxStartupAttempts(): int
+    {
+        return $this->maxStartupAttempts;
+    }
+
+    /**
+     * Get the TLS credentials for gRPC connections.
+     *
+     * @return TlsCredentials|null TLS credentials, or null if not set.
+     */
+    public function getTlsCredentials(): ?TlsCredentials
+    {
+        return $this->tlsCredentials;
+    }
+}