大家好，请指导我如何在实时聊天系统中使用推送器。pusher 安装在我的应用程序中并用于实时通知，但我想在我的消息中添加 pusher。我的消息系统工作正常。请在此处添加推送代码。如果它需要广播事件或通知，你可以告诉我 bcz 我有这个概念。我应该在事件等中添加什么？但我没有推动者的概念。这是 vue js 文件代码。
`data:{ msg: 'my new msg', content: '', privsteMsgs: [], singleMsgs:[], msgFrom: '', conID: '', friend_id: '', seen: false, newMsgFrom: ''`
ready: function(){
this.created();
},
created(){
axios.get('http://localhost:8000/getMessages')
.then(response => {
console.log(response.data); // show if success
app.privsteMsgs = response.data; //we are putting data into our posts array
})
.catch(function (error) {
console.log(error); // run if we have error
});
},
methods:{
message: function(id){
// alert(id);
axios.get('http://localhost:8000/getMessages' +id)
.then(response => {
console.log(response.data); // show if success
app.singleMsgs = response.data;
app.conID = response.data[0].conversation_id;
})
.catch(function (error) {
console.log(error); // run if we have error
});
},
inputHandler(e){
if(e.keyCode===13 && !e.shiftKey){
e.preventDefault();
this.sendMsg();
}
},
sendMsg(){
if(this.msgFrom){
// alert(this.conID);
// alert(this.msgFrom);
axios.post('http://localhost:8000/sendMessage', {
conID: this.conID,
msg: this.msgFrom
})
.then( (response) => {
// console.log('save Successfully');
console.log(response.data); // show if success
if(response.status===200){
console.log('save Successfully')
// console.log('save Successfully'+ data);
app.singleMsgs = response.data;
app.msgFrom= '';
// / app.conID = response.data[0].conversation_id;
}
})
.catch(function (error) {
console.log(error); // run if we have error
});
}
},
friendID: function(id){
app.friend_id = id;
},
sendNewMsg(){
axios.post('http://localhost:8000/sendNewMessage', {
friend_id: this.friend_id,
msg: this.newMsgFrom,
})
.then(function (response) {
console.log(response.data); // show if success
if(response.status===200){
window.location.replace('http://localhost:8000/messages');
app.msg = 'your message has been sent successfully';
}
})
.catch(function (error) {
console.log(error); // run if we have error
});
}
}
这些是路线
Route::get('/messages', function () {
return view('messages');
}); Route::get('/getMessages', function () {
$allUsers1 = DB::table('users')
->Join('conversations','users.id','conversations.user_one')
->where('conversations.user_two', Auth::user()->id)->get();
$allUsers2 = DB::table('users')
->Join('conversations','users.id','conversations.user_two')
->where('conversations.user_one', Auth::user()->id)->get();
return array_merge($allUsers1->toArray(), $allUsers2->toArray());
}); Route::get('/getMessages{id}', function ($id) {
$userMsg = DB::table('messages')
->where('conversation_id', $id)->get();
// echo $userMsg;
return $userMsg;
}); Route::post('/sendMessage','MessagesController@sendMessage');
Route::get('newMessage/{id}','MessagesController@newMessage'); Route::post('sendNewMessage', 'MessagesController@sendNewMessage');
这些是控制器功能
public function sendMessage(Request $request){
$conID= $request->conID;
$msg= $request->msg;
$checkUserId = DB::table('messages')->where('conversation_id', $conID)->get();
if($checkUserId[0]->user_from== Auth::user()->id){
// fetch user_to
$fetch_userTo = DB::table('messages')->where('conversation_id', $conID)
->get();
$userTo = $fetch_userTo[0]->user_to;
}else{
$fetch_userTo = DB::table('messages')->where('conversation_id', $conID)
->get();
$userTo = $fetch_userTo[0]->user_to;
}
// now send message
$sendM = DB::table('messages')->insert([
'user_to' => $userTo,
'user_from' => Auth::user()->id,
'msg' => $msg,
'status' => 1,
'conversation_id' => $conID
]);
if($sendM){
$userMsg = DB::table('messages')
->join('users', 'users.id','messages.user_from')
->where('messages.conversation_id', $conID)->get();
return $userMsg;
}
}
public function newMessage($id){
$uid = Auth::user()->id;
$friend = DB::table('users')->where("id", "=", $id)->first();
return view('newMessage', compact('friend'));
}
public function sendNewMessage(Request $request)
{
$msg = $request->msg;
$friend_id = $request->friend_id;
$myID = Auth::user()->id;
$checkCon1 = DB::table('conversations')->where('user_one',$myID)
->where('user_two',$friend_id)->get();
$checkCon2 = DB::table('conversations')->where('user_two',$myID)
->where('user_one',$friend_id)->get();
$allCons = array_merge($checkCon1->toArray(),$checkCon2->toArray());
if(count($allCons)!=0){
$conID = $allCons[0]->id;
$MsgSent = DB::table('messages')->insert([
'user_from' => $myID,
'user_to' => $friend_id,
'msg' => $msg,
'conversation_id' => $conID,
'status' => 1
]);
}
else{
$con = new Conversation();
$con->user_one = $myID;
$con->user_two = $friend_id;
$con->save();
echo $con->id;
$MsgSent = DB::table('messages')->insert([
'user_from' => $myID,
'user_to' => $friend_id,
'msg' => $msg,
'conversation_id' => $con->id,
'status' => 1
]);
}
}