与拉拉维尔的实时用户消息

Question

我真的需要一些帮助，以及这个问题的例子。我需要在我的网站上有一个像Facebook这样的对话系统(向对话发送消息并在不刷新页面的情况下加载消息)。我认为有很多方法可以解决这个问题：广播、长轮询或简单的 AJAX。如果我能举一个使用广播的例子，将不胜感激。以下是我尝试实现这一点的方法。

表conversations

Schema::create('conversations', function (Blueprint $table) {
$table->increments('id');
$table->integer('user_one')->unsigned()->index()->comment('Sender ID');
$table->foreign('user_one')->references('id')->on('users')->onDelete('cascade');
$table->integer('user_two')->unsigned()->index()->comment('Inrerlocutor's ID');
$table->foreign('user_two')->references('id')->on('users')->onDelete('cascade');
$table->timestamps();
});

表messages

Schema::create('messages', function (Blueprint $table) {
$table->increments('id');
$table->text('message')->comment('Message text');
$table->boolean('is_seen')->default(0);
$table->boolean('deleted_from_sender')->default(0);
$table->boolean('deleted_from_receiver')->default(0);
$table->integer('user_id')->unsigned()->index()->comment('Sender ID');
$table->foreign('user_id')->references('id')->on('users')->onDelete('cascade');
$table->integer('conversation_id')->unsigned()->index()->comment('Conversation ID');
$table->foreign('conversation_id')->references('id')->on('conversations')->onDelete('cascade');
$table->timestamps();
});

控制器

public function sendMessage($id, SendMessageRequest $request)
{
if ($id == Auth::id())
{
return redirect('/');
}
$conversation = Conversation::whereIn('user_one', [Auth::id(), $id])
->whereIn('user_two', [$id, Auth::id()])
->first(); // Get conversation data
/**
* Create a new conv. when doesnt exists
*/
if ($conversation == NULL)
{
$newConversation = Conversation::create([
'user_one' => Auth::id(),
'user_two' => $id,
]);
}
/**
* Create message
*/
Message::create([
'message' => $request->get('message'),
'user_id' => Auth::id(),
'conversation_id' => $conversation !== NULL ? $conversation->id : $newConversation->id,
]);
return redirect(route('mails.chat', $id));
}
/**
* Chat History
*/
public function chat($id)
{
$user = User::find($id); // Get user data
$title = 'Диалог с ' . $user->name . ' ' . $user->lastname; // Page title
if ($id == Auth::id())
{
return redirect('/');
}
$conversation = Conversation::whereIn('user_one', [Auth::id(), $id])
->whereIn('user_two', [$id, Auth::id()])
->first(); // Get conv. data
$messages = '';
if ($conversation !== NULL)
{
$messages = Message::where('conversation_id', $conversation->id)->paginate(30); // Get messages
}
return view('mails.chat', [
'title' => $title,
'conversation' => $conversation,
'messages' => $messages,
'user' => $user,
]);
}

模型对话

class Conversation extends Model
{
protected $table = 'conversations';
protected $fillable = ['user_one', 'user_two'];
protected $dates = ['created_at', 'updated_at'];
public function user() {
return $this->belongsToMany('AppUser');
}
}

模型消息

class Message extends Model
{
protected $table = 'messages';
protected $fillable = ['message', 'is_seen', 'deleted_from_sender', 'deleted_from_receiver', 'user_id', 'conversation_id'];
protected $dates = ['created_at', 'updated_at'];
public function user() {
return $this->belongsToMany('AppUser');
}
public function conversation() {
return $this->belongsToMany('AppConversation');
}
}

视图

@extends('layouts.app')
@section('content')
{{-- Simple display messages --}}
@if ($conversation !== NULL && count($messages) !== 0)
@foreach($messages as $message)
@php($sender = AppUser::find($message->user_id))
<div>
<b>{{ $sender->name }} {{ $sender->lastname }}</b><br>
{{ $message->message }}
</div>
@endforeach
@else
<div class="alert alert-info">No messages.</div>
@endif
<form id="submit" method="post" action="{{ route('mails.sendMessage', $user->id) }}">
{{ csrf_field() }}
<b>Message:</b><br>
<textarea name="message"></textarea>
<button type="submit">Send!</button>
</form>
@endsection

谢谢你帮我解决这个问题。

Answer 1

你要找的是Laravel Echo。这将适用于 redis 服务器、socket.io 和 laravel echo 服务器。它真的很好，易于设置。在此处查看示例应用程序