Gunakan soket untuk membuat bilik sembang peribadi dan awam dalam Node.js_node.js

Saya akan tunjukkan kepada anda rendering dahulu:

Dalam artikel sebelumnya, saya memperkenalkan anda kepada menggunakan Angular, Nodejs dan socket.io untuk membina bilik sembang dan bilik sembang berbilang orang Artikel ini terus memperkenalkan penggunaan soket dalam Node. js untuk membuat bilik sembang peribadi dan awam , sila lihat di bawah untuk butiran khusus.

Antara aplikasi nodejs, socket harus lebih cemerlang dengan berpuluh-puluh ribu bintang di github 🎜>

Untuk contoh, sila klik

http://chat.lovewebgames.com/

Muat turun kod sumber

https://github.com/tianxiangbing/chat

Oleh kerana saya terlalu miskin, pelayan dan pangkalan data semuanya bebas dari luar negara, dan kelajuan akses mungkin perlahan sedikit.

Izinkan saya bercakap dahulu tentang pemahaman saya tentang socket.io lebih seperti membuka perkhidmatan port untuk memantau komunikasi yang lalu. Jadi kita boleh bergantung pada port tapak semasa 80 untuk memulakan perkhidmatan soket, atau kita boleh meletakkannya pada port lain, seperti:

Salin kod Kod adalah seperti berikut:

memerlukan('socket.io').dengar(3000);

Ini untuk memantau port 3000. Memandangkan pelayan percuma yang saya gunakan tidak mempunyai kebenaran untuk membuka port lain, saya masih menggunakan 80. Oleh kerana 80 sudah digunakan oleh ekspres, saya perlu memasukkannya apabila ekspres digunakan.

Salin kod Kod adalah seperti berikut:

pelayan var = http.createServer(app);
soket var = memerlukan(‘./soket/msg’)(pelayan);

Kemudian saya menulis ini dalam msg.js

Salin kod Kod adalah seperti berikut:

var db = memerlukan('../db/mysql');
var sio = memerlukan('socket.io');
var IO = fungsi(pelayan) {
var io = sio.listen(server)

Ini adalah harmoni db ialah kaedah untuk mencipta sambungan mysql, yang tidak disertakan dalam bahagian ini dan ditinggalkan.

Beginilah ia berfungsi dalam socket.io Mula-mula, buat sambungan ke saluran io, dan kemudian pantau peristiwa soket di dalam Nodejs. Kodnya adalah seperti berikut:

Salin kod Kod adalah seperti berikut:

io.on('sambungan', fungsi(soket) {
console.log('seorang pengguna disambungkan.');
​​​​ socket.on('disconnect', function() {
console.log('pengguna diputuskan sambungan.');
        });
})

Selagi pengguna disambungkan pada masa ini, ia akan memasuki sambungan, dan parameternya ialah soket Jika ia adalah sembang awam, kita boleh menggunakannya secara langsung

Salin kod Kod adalah seperti berikut:

io.emit('mesej sembang', {});

Ini borangnya. Tetapi kami sedang mengadakan sembang peribadi di sini, jadi kami perlu menyimpan objek soket ini di dunia global buat sementara waktu, supaya orang yang anda bersembang secara peribadi boleh menggunakannya untuk mencari soket anda Ini sebenarnya sangat berbelit-belit sembang di sini tidak sepenuhnya dari titik ke titik Ia masih melalui pelayan, dan mesej dihantar ke pelayan kemudiannya mencari objek soket orang yang anda ingin sampaikan dan menghantarnya kepadanya. Ini adalah keseluruhan proses. Di sini saya menggunakan objek seperti tatasusunan untuk menyimpannya.

Salin kod Kod adalah seperti berikut:

pengguna var = {},
usocket = {};
socket.on('user join', function(data) {
pengguna[nama pengguna] = nama pengguna;
usocket[nama pengguna] = soket;
})

Memandangkan saya memerlukan nama pengguna untuk log masuk, saya menggunakan nama pengguna sebagai satu-satunya pengecam (ini hanya contoh, jangan bercakap dengan saya tentang nama pengguna pendua. Kelebihan menggunakan borang seperti tatasusunan di sini ialah itu). Saya tidak perlu gelung Anda juga boleh mencarinya dengan cepat. Apabila saya menghantar mesej peribadi kepada A, saya akan menemuinya terlebih dahulu dalam uscoket ini, dan kemudian memanggil emitnya.

function sendUserMsg(data) {
 if (data.to in usocket) {
 console.log('================')
 console.log('to' + data.to, data);
 usocket[data.to].emit('to' + data.to, data);
 usocket[data.user].emit('to' + data.user, data);
 console.log('================')
 }
}

Sebab saya memancarkan dua kali di sini ialah apabila saya menghantar mesej kepada pihak lain, saya juga perlu menerima mesej itu sendiri dan kemudian memaparkannya Mengapa ini? Pertama, antara muka disatukan, dan semua kandungan dalam sembang datang dari pelayan Kedua, ia membuktikan bahawa saya berjaya menghantarnya.

Kemudian apabila saya mendengar pada pelanggan, saya juga menggunakan nama pengguna saya sendiri untuk menyediakan pendengar acara untuk nama pengguna.

socket.on('to' + user, function(data) {
 //console.log(data);
 formatMsg(data);
})

Dengan cara ini, sama ada mesej yang saya hantar atau mesej yang saya terima, ia akan memasuki acara ini. Akhir sekali, jangan lupa untuk memadam objek apabila pengguna pergi.

socket.on('disconnect', function() {
 console.log('disconnect')
 if (username) {
 counter--;
 delete users[username];
 delete usocket[username];
 if (home.name == username) {
  homeLeave(username);
 }
 sendmsg({
  type: 0,
  msg: "用户<b>" + username + "</b>离开聊天室",
  counter: counter,
  users: users
 })
 }
});

Baiklah, anda sudah selesai.