我使用、socket.io、mysql2 和 express 包建立了一個帶有 NodeJs 的聊天室。它非常動態，包括公共聊天、私人訊息和其他使其生動的獨特功能，即實時更新、通知等。
最初在一個虛擬域上構建和測驗，并且運行良好。完成后，我將其移至我的主要網站域。既然如此，我正在經歷可怕的網站加載速度。但是，兩個域（測驗域站點和主要實時站點位于同一臺服務器上）。
服務器; 2 個英特爾? 至強? 處理器 E5-2697 v4、64GB RAM、4 個 480GB SSD、硬體 RAID 存盤、1 Gbps 網路埠、2 個 ipv4 地址、50 TB 帶寬、Centos 7、cpanel 包括并擁有。大約 1000 名用戶積極使用該網站/聊天。聊天室對網站的其他部分產生了負面影響并減慢了速度。初始服務器回應時間大約為 14 秒，但在最壞的情況下長達 30 多秒。而在測驗域上，它實際上只有 1 秒。不用說，我應該期望在原始測驗域上的加載時間與真實用戶的實時加載時間一樣好，但這很糟糕嗎？我跑題了。
我進行了速度測驗。這些測驗的結果不斷向我報告初始加載時間太長，并且沒有具體說明問題是什么，所以我認為它是 MYSQL、php 等等。我盡我所能對它進行了優化。但是在網站不斷拖后，我仍然得到相同的結果。我終于從網站上一一洗掉了東西，當我洗掉聊天時，網站加載得很好。這很奇怪，因為沒有任何速度測驗表明聊天或節點特別是推理。
于是我就通過以下方式優化了Node。-我嘗試將池添加到 sql 連接，嘗試不同的數字，從 5 到 500，-我嘗試將 PoolManager 添加到資料庫連接。-我洗掉了所有訪問者保持連接到我們的節點服務器的能力。如果它們并不意味著某些 cretia，它們的套接字連接將被終止。-我在代碼中添加了一些并行化。運行一些呼叫資料庫的函式。-我確保添加鍵并避免長 sql 查詢，使用 LIMIT，并避免 *
把它放回網站上，仍然是同樣可怕的加載時間。
經過一些研究，我希望（但仍然只是猜測）以下可能引起關注；
- 服務器默認為輪詢。所以也許這可能會導致問題。因為我假設每次輪詢它都必須連接和斷開與資料庫服務器的連接，這將導致相當大的延遲，因為我讀到存在很多問題。-我試圖修復投票，但無法使其正常作業。我嘗試強制運輸：
['網路套接字']
，具有所有不同型別的設定、CORS、安全等。
我讀到可能使用 Redis 進行快取，我認為它肯定可以在某些領域實作。但是聊天是多么的熱鬧。快取的使用頻率可能會受到限制。
如果我自己的代碼有任何問題，我可能會猜到它在這里。
//server
const f = require('./functions.js');
const db = require('./db.js');
const cookie = require('cookie');
const http = require("http");
const express = require("express");
const { Server } = require("socket.io");
const port = 3000;
const appBaseUrl = "/node";
const socketBaseUrl = "/node/socket";
global.last_message_time = new Date('1995-12-17T03:24:00');
// Create the server and socket
const expressApp = express();
const nodeServer = http.createServer(expressApp);
const socketIo = new Server(nodeServer, {
path: socketBaseUrl,
});
//client
const chat = io.connect("domain.com", {path: "/node/socket"});
But at the end of the day I am still at a loss and so I look to you and throw myself at the mercy of StackOverflow. Opinions, feedback and ideas as to why the chat is not playing nicely with my website would be more appreciated than you know. Thank you in advance and I look forward to hearing from you.
------------------------------Update
@Ga?tan Boyals - the additional code you asked for concerning where messages are handled, below.
let chats = []
await db.getMessages(data.id, user.user_id, user.isAdmin, 'user')
.then(response=>{
chats = response.reverse();
}).catch((err)=>{
console.log(err);
})
let chats_html = [];
for(let chat of chats){
chat.message_type = chat.type;
chat.images = [];
chat.small = [];
if(chat.type=='photos'){
let encoded = JSON.parse(chat.message);
for(let small of encoded){
let j = f.createToken(small);
chat.small.push(j "?height=150");
chat.images.push(j)
;
}
}
//might cause issues later so see what's up here.
chat.emojis = await db.getEmojiReactions(1, chat.id);
chat.avatar = f.createToken(chat.avatar);
chats_html.push(f.createMessage(chat, user.user_id, user.user_type));
}
let chat_info = await db.getPrivateRoom(data.id, user.user_id);
socket.join(chat_info);
user.current_room = data.id;
user.current_type = 'user';
user.room = chat_info;
let send = {chats:chats_html};
socketIo.to(socket.id).emit('get-chat', send);
let best_badge = await db.bestBadge(data.id);
let user_1 = await db.getUserFromId(data.id);
user_1.badge = best_badge ? best_badge.badge_id:false;
user_1.avatar = f.createToken(user_1.avatar);
let group_user_html = [];
group_user_html.push(f.rightSideUsers(user_1));
group_user_html.push(f.rightSideUsers(user));
socketIo.to(socket.id).emit('right-users', group_user_html);
if(user.current_room != 0){
let isMuted = false;
if(data.type=='group'){
isMuted = await db.isMuted(user.user_id, data.id);
}
if(!isMuted){
data.user_id = user.user_id;
data.to = data.id;
if(data.message_type == 'photos'){
data.message = JSON.stringify(data.message);
}
if(user.user_id==0){
data.guest = user.username;
}
db.newMessage(data)
.then((response)=>{
if(response){
if(data.type=='group'){
db.setChatMeta(response, 'group', data.id,user.user_id);
}else{
db.setChatMeta(response, 'user', data.id,user.room);
}
data.id = response;
data.chat_id = response;
let html = f.createMessage(data, user.user_id, user.user_type);
let new_data = f.createRightData(data);
new_data.message = new_data.message.replace('<br />', '');
let uni = user.room;
let send = {html:html, id:uni,type:data.type}
if(data.message_type == 'video'){
setTimeout(()=>{
socketIo.in(user.room).emit("new-message",send);
socketIo.emit('refresh');
}, 5000)
}else{
console.log(user.room);
socketIo.in(user.room).emit("new-message",send);
socketIo.emit('refresh');
}
}
}).catch((err)=>{
console.log(err)
})
}else{
socketIo.to(socket.id).emit('muted')
}
}
GET and SET messages.
uj5u.com熱心網友回復：
據我所知，我相信您的服務器正在以某種方式填充以創建 Web 套接字連接并使用輪詢作為后備。這基本上意味著巨大的開銷。您能否將聊天功能分離到單獨的節點應用程式并可能將其容器化？進行初始站點加載，然后加載聊天功能，直到您弄清楚根本原因是什么。
uj5u.com熱心網友回復：
您的 12 核服務器根本不是很大，至少在組合多個應用程式時是這樣。如果資料庫使用所有 12 核并且 Node.js 應用程式使用 1 核，但在某些情況下，您的里程可能會發生很大變化，但 Node.js 應用程式會受到很大影響。
現在我不知道您的網站有多大，有多少用戶訪問該網站，但是 12 核的電源是很多電源...
1 個核心電源我的 HTTP 服務器可以每小時處理一百萬個請求，但會出現“多次超時”，但這會影響不同服務器上的單個核心資料庫。因此，如果我們在這里進行數學運算，我們會收到很多請求，您可以進行基準測驗以了解自己。
OP 的問題是他們沒有正確使用 Node.JS。他們正在運行使用單核的應用程式的單個實體，并且 HTTPS 與 websockets 共享，這嚴重限制了服務到 HTTPS/WSS 的單核。
該解決方案正在變得無狀態，并將單核 Node.JS 應用程式轉變為多核應用程式。這需要一些關于垂直縮放和水平縮放應用程式的知識。因此，有了這些數字，OP 作為回應發布了一個單一的核心，這是直接踢。
祝你好運，由于 12 核并且您沒有托管媒體服務器，我現在將這歸咎于 NodeJS。干杯。
uj5u.com熱心網友回復：
用戶@S1ckhead 已經部分說明了我將要解釋的內容，但我會嘗試更詳細地介紹。
正如我在評論中所說，請記住這是我認為正在發生的事情，但話又說回來，@S1ckhead 似乎和我有大致相同的想法，所以你可能想繼續閱讀，即使它不會提供完整的-烘焙的解決方案。
這不是硬體相關的問題
當然，我們可以吹噓我們的個人設定，既然我們已經這樣做了，如果我可以運行一個自托管的裸機 K8s 集群，其中三臺 2006 戴爾 PC 處理一個 Redis 實體、一個 MongoDB 實體和大約 30 個微服務，我覺得OP可以運行PHP的網站，一個服務的NodeJS和MySQL實體與他在他的問題給出了規范就好了。見鬼，當我還是某家公司的員工時，我什至可以用他整個規格的 1/3 的預算來運行 ElasticSearch。
他提到就這個問題聯系他的主人并問他們是否應該升級，他們說不，我認為他們是最有資格這么說的人。
另外，想象一下每臺服務器只運行一個實體（Php、MySQL，你的名字）......我們并不都是比爾蓋茨，我們也沒有必要這樣做。
反向代理？路由？
我假設您在系統管理員/網路方面具有基本或中級水平，因為您知道如何設定域并將其鏈接到您的服務器。
反向代理基本上是一種將客戶端請求路由到特定應用程式的軟體。例如，假設您有 3 個域（domainA.com、domainB.com、domainC.com），它們都指向同一個 IP 地址（基本上是同一臺機器）。服務器如何知道 domainA 應該訪問 PHP 站點，而 domainB 應該訪問 NodeJS 服務？這就是反向代理派上用場的地方。這是非常粗略的解釋，但你可以在這里找到更多解釋，如果你像我一樣喜歡圖形表示，這里有一個：
現在，我不會說謊，我不熟悉，在所有與的cPanel，PHP和這樣的，我經常去的基于無的NodeJS -管理工具路線和主機應用程式，但你一定能夠建立一個反向代理你的設定。
真正的問題是什么
再次提到@S1ckhead，Socket.IO 可能默認使用長輪詢，但為什么呢？
由于在您的代碼中，您讓 socketIO 監聽您的主域：const chat = io.connect("domain.com", {path: "/node/socket"});，WebSocket 請求可能會轉到您的 PHP 應用程式。但是您的 PHP 應用程式可能未配置為處理 WebSockets 請求，只有 HTTP 請求，因此它默認為長輪詢。你可以在這里閱讀更多內容，但基本上，說明這個網站：
服務器保持請求打開，直到有新資料可用。一旦可用，服務器就會回應并發送新資訊。
因此，由于它會一直保留請求，直到發生新的事情，它可以解釋為什么您會體驗到這種極其滯后的感覺。
你該怎么辦？
Well, you could go two routes, the first one and the easiest would be to loan a new server, buy another domain or subdomain, link the two together, host your NodeJS app here and link your main site to this new domain/subdomain.
The other, greatly reducing costs, would be to setup a reverse proxy as previously mentioned. It could prove to be a difficult challenge (I did it with no previous experience myself, but I also had no work obligations/pressure to do it) however. It is up to you and your constraints/requirements to chose which one you want to follow.
Of course, other problems will arise when your pool of user grow larger, and the question of scaling will make sense, but that's not the concern right now.
A final note on Socket.IO
請記住，Socket.IO 是Web Socket 協議的包裝器，并且它只能與它的客戶端/服務器對應物一起使用（這意味著您不能將自己的 WebSockets 客戶端實作與 Socket.IO 服務器連接起來，反之亦然）反之亦然）。這可能意味著您必須撰寫自己的 WebSockets 實作，因為我似乎無法在 PHP 中找到 Socket.IO 的最新實作。（我什至不知道這是否可能，再說一次，我不是 PHP 專家）
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/409206.html
標籤：