Я работаю над системой обмена личными сообщениями в реальном времени в своем php-приложении. Мои коды работают для всех пользователей вместе. Но мне нужна система обмена личными сообщениями как личное сообщение.
После настройки node и redis я могу получить данные сообщения, которые мне нужны: вот код ::
Внешний интерфейс :: 1. Я использую форму для имени пользователя, сообщения и кнопки отправки.
и уведомления JS:
$( document ).ready(function() {
var socket = io.connect('http://192.168.2.111:8890');
socket.on('notification', function (data) {
var message = JSON.parse(data);
$( "#notifications" ).prepend("<p> <strong> " + message.user_name + "</strong>: " + message.message + "</p>" );
});
});
JS на стороне сервера:
var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);
var redis = require('redis');
server.listen(8890);
var users = {};
var sockets = {};
io.on('connection', function (socket) {
console.log(" New User Connected ");
// instance of Redis Client
var redisClient = redis.createClient();
redisClient.subscribe('notification');
socket.on('set nickname', function (name) {
socket.set('nickname', name, function () {
socket.emit('ready');
});
});
socket.on('msg', function () {
socket.get('nickname', function (err, name) {
console.log('Chat message by ', name);
});
});
redisClient.on("message", function(channel, message)
{
// to view into terminal for monitoring
console.log("Message from: " + message + ". In channel: " + channel + ". Socket ID "+ socket.id );
//send to socket
socket.emit(channel, message);
});
redisClient.on('update_chatter_count', function(data)
{
socket.emit('count_chatters', data);
});
//close redis
socket.on('disconnect', function()
{
redisClient.quit();
});
});
HTML::
<script src="https://cdn.socket.io/socket.io-1.3.5.js"></script>
<form .....>
<input ....... >
</form>
<div id="notifications" ></div>
Общий результат:
John : Hello
Kate : Hi
Others: .....
Вышеуказанные коды прекрасно работают в моем приложении php. Теперь я хочу настроить частную или индивидуальную систему обмена сообщениями.
Как мне нужно добавить имя пользователя или адрес электронной почты или уникальный идентификатор сокета для пользователя. У меня больше нет идей для личных сообщений. Я пытался вычислить в Интернете, но не смог.
** Как мне настроить личное сообщение в моем приложении php? **
