Laravel WebSocket 在发出 POST 请求时出现 Pusher 错误

Question

我正在尝试将网络套接字集成到我的 laravel 项目中。我完成了 here

的所有步骤

composer require pusher/pusher-php-server
/Users/alpha/Sites/jdoe/config/broadcasting.php


https://dashboard.pusher.com/apps/888



app_id = "888"
key = "***"
secret = "333"
cluster = "us2"



|
V


BROADCAST_DRIVER=pusher
PUSHER_APP_ID=888
PUSHER_APP_KEY=***
PUSHER_APP_SECRET=333
PUSHER_APP_CLUSTER=us2


.env.example + .env 

npm install --save laravel-echo pusher-js


npm run watch 


---------------------------------------------------


php artisan make:event logEvent


<?php

namespace App\Events;

use Illuminate\Broadcasting\Channel;
use Illuminate\Queue\SerializesModels;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Broadcasting\PresenceChannel;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;

class logEvent implements ShouldBroadcast
{
    use Dispatchable, InteractsWithSockets, SerializesModels;

    private $data;

    /**
     * Create a new event instance.
     *
     * @return void
     */
    public function __construct($data)
    {
        $this->data = $data;
    }

    /**
     * Get the channels the event should broadcast on.
     *
     * @return \Illuminate\Broadcasting\Channel|array
     */
    public function broadcastOn()
    {
        return new Channel('logEventChannel');
    }

    public function broadcastWith()
    {
        return [
            'data' => $this->data
        ];
    }
}

---------------------------------------------------



/Users/alpha/Sites/jdoe/resources/js/app.js



require('./bootstrap');


Echo.channel('logEventChannel').listen('logEvent', (e) => {

    // console.log(typeof JSON.parse(JSON.stringify(e))) //object
    // console.log(typeof JSON.parse(JSON.stringify(e.data))) //string
    // console.log(JSON.parse(e.data)); //decode or parse it

    let data = JSON.parse(e.data);

    /*=============================
    =            Debug            =
    =============================*/

    console.log('data ===== ',data);

    

});




---------------------------------------------------

route



Route::post('ws/log', 'BroadcastController@logEvent');




---------------------------------------------------
Controller



<?php

namespace App\Http\Controllers;

use App\Events\LogEvent;
use Illuminate\Http\Request;

class BroadcastController extends Controller
{

    public function vnfevent(Request $request)
    {

        $body            = json_decode($request->getContent(),true);
        dd($body); 
        $json = json_encode($body);

        broadcast(new LogEvent($json));

        return response()->json($body,200);

    }

}


---------------------------------------------------
CSRF


/Users/alpha/Sites/jdoe/app/Http/Middleware/VerifyCsrfToken.php


protected $except = [
'/ws/log'
];



---------------------------------------------------
TEST

POSTman

ws/log


{
    "type": "poop"
}



place a dd in broadbast 


arrived !! 

array:1 [
  "type" => "poop"
]




ErrorException: array_merge(): Expected parameter 2 to be an array, null given in file

---------------------------------------------------
Debug the crashing line 

/Users/alpha/Sites/jdoe/vendor/pusher/pusher-php-server/src/Pusher.php


dd($post_params, $params);
$all_params = array_merge($post_params, $params);




array:3 [▼
  "name" => "App\Events\logEvent"
  "data" => array:1 [▼
    "data" => "{"type":"poop"}"
  ]
  "channels" => array:1 [▼
    0 => "logEventChannel"
  ]
]


Look correct

我测试了 post 我的 /ws/log

{
    "type": "poop"
}

我不断得到

ErrorException: array_merge(): Expected parameter 2 to be an array, null given in file /Users/alpha/Sites/jdoe/vendor/pusher/pusher-php-server/src/Pusher.php on line 518

我打开了那个文件

$all_params = array_merge($post_params, $params);

$params 一些方式 = null

如何继续进一步调试？

编辑

我删除了我的 vendor/ 并按照建议尝试了 4.1 版。

"require": {
    "php": "^7.2.5",
    "doctrine/dbal": "^2.10",
    "fideloper/proxy": "^4.2",
    "fruitcake/laravel-cors": "^1.0",
    "guzzlehttp/guzzle": "^6.3",
    "intervention/image": "^2.3",
    "laravel/framework": "^7.0",
    "laravel/tinker": "^2.0",
    "laravelcollective/html": "~6.0",
    "pusher/pusher-php-server":"^4.1"
},

通过 POSTman 向我的路线发送 POST 时，我仍然遇到问题。

Answer 1

所以对于这个问题，实际上这是 Laravel 中的一个问题，现在已经解决了使用 (laravel 8.29.0) 或更高版本。
所以 pusher-http-php library v5.0.1 和 Laravel v8.29.0 将适合你。

另一个解决方案： 是在 composer.json 上将 pusher 降级到 4.1 版本，这个版本似乎可以很好地与旧的 laravel 版本（早于 8.29 .0).

如果您想解决当前安装的问题：

问题是触发函数的调用，至少在 laravel 8 上没有发送正确的参数，所以在 PusherBroadcaster.php 和 pusher-php-server/Pusher.php 中有 2 次触发函数调用它们是：

$this->pusher->trigger(
$this->formatChannels($channels), $event, $payload, $socket, true
);

和

public function trigger($channels, $event, $data, $params = array(), $already_encoded = false)

您只需要更改 Pusher。

1- 更改（第 496 行）。

$data_encoded = $this->crypto->encrypt_payload($channels[0], $already_encoded ? $data : json_encode($data));

收件人：

$data_encoded = $this->crypto->encrypt_payload($channels[0], $already_encoded && !is_array( $data) ? $data : json_encode($data));

2- 更改（第 499 行）。

$data_encoded = $already_encoded ? $data : json_encode($data);

收件人：

$data_encoded = $already_encoded && !is_array( $data) ? $data : json_encode($data);

3- 更改（第 518 行）

$all_params = array_merge($post_params, $params);

收件人：

$all_params = array_merge($post_params, is_array($params) ? $params:[]);

4- 更改（第 542 行）

return $result;

收件人：

return $response;

这会让它适合你。

注意： 正如我所说，它已在 Laravel 的 v8.29.0 中解决。 Link
注意： 或者你可以使用composer require pusher/pusher-php-server ^4.1

注意：
主要问题是 $param 在这种情况下是 null 并且它没有检查这个值是否是 array() 所以当代码试图合并 array() 与 null.

资源：

Link_1 Link_2

Laravel WebSocket 在发出 POST 请求时出现 Pusher 错误

Laravel WebSocket with Pusher Error when making POST Request

php

laravel

laravel-7

pusher

编辑