怎么把JAVA的数据发送到nodejs服务器上

Posted 2023-03-23

1. 首先需要一个消息监听器类
package com.sogou.baike.testimport.testSubscribe;

import redis.clients.jedis.JedisPubSub;

/**
* Created by denglinjie on 2016/6/29.
*/
public class RedisMsgPubSubListener extends JedisPubSub
@Override
public void unsubscribe()
super.unsubscribe();


@Override
public void unsubscribe(String... channels)
super.unsubscribe(channels);


@Override
public void subscribe(String... channels)
super.subscribe(channels);


@Override
public void psubscribe(String... patterns)
super.psubscribe(patterns);


@Override
public void punsubscribe()
super.punsubscribe();


@Override
public void punsubscribe(String... patterns)
super.punsubscribe(patterns);


@Override
public void onMessage(String channel, String message)
System.out.println("channel:" + channel + "receives message :" + message);
this.unsubscribe();


@Override
public void onPMessage(String pattern, String channel, String message)



@Override
public void onSubscribe(String channel, int subscribedChannels)
System.out.println("channel:" + channel + "is been subscribed:" + subscribedChannels);


@Override
public void onPUnsubscribe(String pattern, int subscribedChannels)



@Override
public void onPSubscribe(String pattern, int subscribedChannels)



@Override
public void onUnsubscribe(String channel, int subscribedChannels)
System.out.println("channel:" + channel + "is been unsubscribed:" + subscribedChannels);


该类需要继承JedisPubSub ，并实现其抽象方法，通过方法的名称很清楚的看出来，这个监听器是用来订阅一个频道，在订阅该频道，取消订阅，收到消息等状态会对应调用相关的方法
2. 订阅测试类
public class TestSubscribe
@Test
public void testSubscribe() throws Exception
Jedis jedis = new Jedis("localhost");
RedisMsgPubSubListener listener = new RedisMsgPubSubListener();
jedis.subscribe(listener, "redisChatTest");
//other code


该类实现对频道redisChatTest的订阅监听，频道的订阅，取消订阅，收到消息都会调用listener对象的对应方法

注意：subscribe是一个阻塞的方法，在取消订阅该频道前，会一直阻塞在这，只有当取消了订阅才会执行下面的other code，参考上面代码，我在onMessage里面收到消息后，调用了this.unsubscribe(); 来取消订阅，这样才会执行后面的other code
3. 发布消息测试类
Public class TestPublish
@Test
public void testPublish() throws Exception
Jedis jedis = new Jedis("localhost");
jedis.publish("redisChatTest", "我是天才");
Thread.sleep(5000);
jedis.publish("redisChatTest", "我牛逼");
Thread.sleep(5000);
jedis.publish("redisChatTest", "哈哈");


这个类向频道redisChatTest发布消息，第二步因为订阅了该频道，所以会收到该消息。 参考技术A 数据库拷贝和解析就好

从服务器发送数据到客户端Nodejs

【中文标题】从服务器发送数据到客户端Nodejs

【英文标题】：data sending from server to client-side Nodejs

【发布时间】：2022-01-12 08:24:38

【问题描述】：

我提出了一个发帖请求。我想执行一些操作并将数据发送回客户端，基于我的前端将更改。该怎么做？？

【问题讨论】：

您可以简单地让您的前端发出第二个 GET 请求来检索新数据并自行更新。

【参考方案1】：

您可以在进行更改后简单地获得对发布请求的响应。 如果更改花费了太多时间并导致超时，有两种可能的方式来进行：

在前端设置超时并发出获取请求以获取数据。 查看socket.io。 （这是一种更好的处理方式 因为您可以在前端设置一个侦听器以接收来自的任何数据 后端。）

【参考方案2】：

在服务器端可以写

var express = require('express');
var app = express();
app.listen('3000')

app.post("/getdata", (req, res) => 
    res.send(//any json data)
)

在你的客户端你可以写

var output = false
fetch("your server link or if you are on local server then 
http://localhost:3000/getdata", method: 'POST')
.then(data => return data.json()).then(data => output = data)

现在您在客户端网页的 var 输出中得到了结果

【讨论】：

页面重定向到我发送的 json 输出。我想留在上一页并对其进行更改