php - 如何创建从 nodejs mysql 模块获取的正确的 json 类型数据？

Question

伙计们，我已经在我的网络项目上工作了很长时间。我现在正在创建一个实时通知系统，我正在使用 node js + socket io。我很高兴在 stackoverflow 专家的帮助下，我能够在不同的 port 上同时运行 apache server 和 nodejs server对于一个完整的 Web 应用程序。好的，现在让我们进入正题。

与我的逻辑人员一起，我试图通过两个步骤进行实时通知:-

1) 首先，用户通过客户端页面连接套接字，然后它发出 连接事件，该事件由我们的 nodejs 服务器文件处理。

2) 在检测到用户已连接到套接字后，我在 nodejs 中执行了一些 mysql 获取，使服务器文件如下:-

// ....all module are presented here above...

io.sockets.on('connection', function(client) {
  var pool = mysql.createPool({
    connectionLimit: 10,
    host: "localhost",
    user: "root",
    password: "",
    database: "mydatabase"
  });

  pool.getConnection(function(err, connection) {
    var queryString = "Select * from table_one";
    connection.query(queryString, function(error, results) {
      if (error) {
        throw error;
      } else {
        console.log("New client !");
        io.sockets.emit('u_d', results);
      }
    });
    connection.release();
  });
});

上面我使用了 nodejs mysql 模块。它从该表名 table_one 中获取所有数据，数据类型为 json ，如图中所示以下。

你可以看到我在 json 类型上获取了我的数据。是否有可能使我的 json 数据以正确的格式获取，如下所示:-

{
  "result": [{
      "id": "2",
      "user": "hari061",
      "pic": "img.jpg"
    },
    {
      "id": "3",
      "user": "ram061",
      "pic": "nature.jpg"
    }
  ]
}

该 json 数据将在此处交给我的客户端:-

var socket = io.connect('http://localhost:3000');

socket.on('u_d', function(data) {
  $('.display_noti').append($('<li style="margin-bottom:10px;margin-left:10px; margin-right:10px;">').text(data));
});

毕竟我发现了两个问题:-

1) 在用户的每个连接中 mysql 获取数据。(这意味着我的用户每次都应该连接到套接字以进行新的更新)。这不是实时的，我的意思是页面重新加载只能使该用户连接到套接字，然后才会显示他/她的新更新。

2) 正如我发现 mysql 获取的数据以 json 格式检索。我想控制适合我的 json 格式的结果客户端。

我怎样才能解决这两个问题？

Answer 1

如果您在服务器外部修改数据，您可以添加一些 RESTful API 来触发服务器更新数据:

# example with express.js
app.put '/newdata/', (req, res) ->
    get_updated_data (result) ->
        io.sockets.emit 'u_d', result       # send new update to all connected clients

按照这种逻辑，当用户连接时，您应该将数据的“最后状态”发送给新客户端:

io.sockets.on 'connection', (client) ->
    get_last_state (result) ->
        client.emit 'last state', result    # send last state to new client

一行简单的 JSON 格式化:

JSON.stringify jsonObject, null, '\t'

和here你可以阅读更多如何美化 JSON 字符串。

此外，如果您在 io 的connection 之外放置对 MySQL 的连接调用，您将在每次客户端连接到套接字时节省 MySQL 连接/断开连接的资源。