Nodejs：求助 从Java端获取数据

Nodejs：求助 从Java端获取数据

想实现服务器端推送至前端，利用Node实现推送，但是数据时由Java获取的，请问各位如何通信？

谢谢~

5 回复

当然可以！假设你有一个Java后端服务已经在运行，并且你可以通过HTTP接口获取数据。你可以使用Node.js来调用这个Java服务并获取数据，然后将这些数据推送到前端。下面是一个简单的示例来展示如何实现这一过程。

1. 使用Node.js调用Java服务

首先，你需要一个Node.js应用来调用Java服务并获取数据。这里我们可以使用axios库来发送HTTP请求。

安装axios

npm install axios

示例代码

const express = require('express');
const axios = require('axios');

const app = express();
const port = 3000;

// 获取数据的API路径
const javaApiUrl = 'http://localhost:8080/java-data';

app.get('/get-data', async (req, res) => {
    try {
        // 调用Java服务获取数据
        const response = await axios.get(javaApiUrl);
        
        // 将获取的数据返回给客户端
        res.json(response.data);
    } catch (error) {
        console.error("Error fetching data from Java service:", error);
        res.status(500).send("Error fetching data");
    }
});

// 启动服务器
app.listen(port, () => {
    console.log(`Server running at http://localhost:${port}`);
});

2. 推送数据到前端

接下来，你需要一种机制将数据推送到前端。这里可以使用WebSocket来实现实时数据推送。

安装WebSocket库

npm install ws

示例代码

const WebSocket = require('ws');

// 创建WebSocket服务器
const wss = new WebSocket.Server({ port: 8081 });

wss.on('connection', (ws) => {
    console.log('Client connected');

    // 当有新数据时，向所有连接的客户端发送数据
    setInterval(() => {
        axios.get(javaApiUrl)
            .then((response) => {
                ws.send(JSON.stringify(response.data));
            })
            .catch((error) => {
                console.error("Error fetching data:", error);
            });
    }, 5000); // 每5秒更新一次数据
});

console.log('WebSocket server is running on ws://localhost:8081');

3. 前端接收数据

最后，你需要在前端使用WebSocket来接收数据。

示例代码（HTML + JavaScript）

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>WebSocket Client</title>
</head>
<body>
    <h1>Real-time Data</h1>
    <div id="data"></div>

    <script>
        const socket = new WebSocket('ws://localhost:8081');

        socket.onmessage = function(event) {
            const dataDiv = document.getElementById('data');
            dataDiv.innerHTML = JSON.parse(event.data);
        };

        socket.onopen = function() {
            console.log('Connected to WebSocket server');
        };

        socket.onclose = function() {
            console.log('Disconnected from WebSocket server');
        };
    </script>
</body>
</html>

总结

以上代码展示了如何使用Node.js调用Java服务获取数据，并通过WebSocket将实时数据推送到前端。你可以根据实际需求调整HTTP请求的频率、错误处理逻辑等细节。希望这对你有所帮助！


我们当时前端用php，都是json

java 写好服务器，node服务器从java服务器取数据，发向客户端。 跟node服务器获取mongodb服务器的数据一个道理。

http+hessian就可以了吧

为了实现从Java端获取数据并推送到前端，你可以通过Node.js作为中间层来处理这种场景。基本思路是：

  1. Java服务：首先运行一个Java服务，它负责获取数据。
  2. Node.js服务：Node.js服务与Java服务进行通信以获取数据，并将这些数据推送给前端。

示例

Java端（获取数据）

假设你的Java服务有一个HTTP接口可以获取数据：

@RestController
public class DataController {
    @GetMapping("/getData")
    public Map<String, String> getData() {
        // 模拟数据获取
        return new HashMap<String, String>() {{
            put("message", "Hello from Java!");
        }};
    }
}

Node.js端（获取Java数据并推送到前端）

在Node.js中，我们可以使用axios或http模块来请求Java服务的数据，并使用socket.io来实现实时推送：

首先，安装必要的包：

npm install express socket.io axios

然后创建一个简单的Node.js应用：

const express = require('express');
const http = require('http');
const socketIo = require('socket.io');
const axios = require('axios');

const app = express();
const server = http.createServer(app);
const io = socketIo(server);

app.get('/', (req, res) => {
  res.send('Socket.IO server is running');
});

// 使用axios定期请求Java服务的数据
setInterval(async () => {
  try {
    const response = await axios.get('http://localhost:8080/getData');
    io.emit('newData', response.data);
  } catch (error) {
    console.error('Error fetching data from Java service:', error);
  }
}, 5000); // 每5秒获取一次数据

io.on('connection', (socket) => {
  console.log('A user connected');
});

server.listen(3000, () => {
  console.log('Node.js server listening on port 3000');
});

解释

  • Java部分：定义了一个简单的REST API /getData，返回模拟数据。
  • Node.js部分：
    • 创建了一个Express服务器，并配置了Socket.IO以支持WebSocket连接。
    • 使用axios定期（每5秒）请求Java服务的数据，并通过Socket.IO广播给所有连接的客户端。
    • 客户端可以通过监听newData事件来接收新数据。

这样，前端就可以通过WebSocket实时接收到来自Java后端的数据更新。

回到顶部