[Support] 使用sse返回的第一条数据会出现[object Object] #4174
-
Describe the problem（描述问题）使用sse返回数据，但是返回的数据中意外地出现了[object Object]，这影响到了我的解析。虽然可以加以处理，但是会引起我的不安。 import {
Inject,
Controller,
Get,
Query,
HttpServerResponse,
} from '@midwayjs/core';
import { Context } from '@midwayjs/koa';
import { UserService } from '../service/user.service';
@Controller('/api')
export class APIController {
@Inject()
ctx: Context;
@Inject()
userService: UserService;
@Get('/get_user')
async getUser(@Query('uid') uid) {
const res = new HttpServerResponse(this.ctx).sse();
setTimeout(() => {
res.send({
data: 'test',
});
res.end();
}, 3000);
return res;
}
}返回的结果 Midway Versions（Midway 版本）
✓ @midwayjs/faas-typings(not installed)
|
Beta Was this translation helpful? Give feedback.
Replies: 3 comments 9 replies
-
const res = new HttpServerResponse(this.ctx).sse();
setTimeout(() => {
res.send({
data: 'test',
});
res.end();
}, 3000);
return res;代码返回的 res 确是是个对象啊。setTimeout 应该改成 Promise 并返回这个 Promise |
Beta Was this translation helpful? Give feedback.
-
|
谢谢您给的建议，对您给的建议我进行了如下尝试，此时返回的结果是 abc ，明显不符合预期。 import {
Inject,
Controller,
Get,
Query,
HttpServerResponse,
} from '@midwayjs/core';
import { Context } from '@midwayjs/koa';
import { UserService } from '../service/user.service';
@Controller('/api')
export class APIController {
@Inject()
ctx: Context;
@Inject()
userService: UserService;
@Get('/get_user')
async getUser(@Query('uid') uid) {
const res = new HttpServerResponse(this.ctx).sse();
return new Promise((resolve) => {
setTimeout(() => {
res.send({
data: 'test',
});
res.end();
resolve('abc');
}, 3000);
});
}
}从midway官方文档上看，是需要将该实例返回的。 |
Beta Was this translation helpful? Give feedback.
-
|
try: return new Promise((resolve) => {
setTimeout(() => {
res.send({
data: 'test',
});
res.end();
resolve(res); // <===
}, 3000);
}); |
Beta Was this translation helpful? Give feedback.
-
|
针对您给出的最近的建议我进行了更改，但是问题依旧存在： |
Beta Was this translation helpful? Give feedback.
-
|
请使用 EventSource 来接收数据，如果想打印在页面上，使用 |
Beta Was this translation helpful? Give feedback.
-
|
您好！谢谢您的回答，我根据您给的方法进行测试。[object Object]还是会不可避免地出现在第一次回答中。我想这应该不是前端发送请求的方式和如何进行接收的问题。 |
Beta Was this translation helpful? Give feedback.
-
|
你没有明白，不能直接用网页（包括查看响应）来查看 SSE 的返回，你需要使用 "EventSource" 对象来获取。 |
Beta Was this translation helpful? Give feedback.
-
|
我想应该是可以直接使用网页（包括查看响应）来查看 SSE 的返回。如果使用 fetch 请求一个sse接口，其获取的是一个流式响应，获取的数据是原始的文本数据。只是相较于使用 EventSource，使用fetch的方式则需要自己解析。 我使用nest做了一个小demo进行测试，发现其返回的数据中没有带上不符合预期的字符。但是在midway中使用sse返回的第一条数据中带有 [object Object] ，这很意外，不清楚是 midway 的设计还是其他的问题。 import { Controller, Get, Res, Sse } from '@nestjs/common';
import { AppService } from './app.service';
import { interval, map, Observable, take } from 'rxjs';
/**
* AppController 负责处理 HTTP 请求和 SSE 事件流。
*/
@Controller()
export class AppController {
constructor(private readonly appService: AppService) {}
/**
* 处理 SSE 请求，每秒向客户端发送一次 "Hello World" 消息。
* @returns 一个 Observable 对象，包含 SSE 事件流。
*/
@Sse('sse')
sse(): Observable<MessageEvent> {
return interval(1000).pipe(
map(() => {
const data = { event: 'tick', data: { hello: 'world' } };
return new MessageEvent(data.event, {
data: JSON.stringify(data.data),
});
}),
take(5), // 只发送5个事件
);
}
}
|
Beta Was this translation helpful? Give feedback.
-
|
大概知道原因了，在第一次数据传输时，发送了一个{data: ' :ok'} 对象，这个逻辑参考了社区库的实现，有点问题，正确的应该拿到 才对 |
Beta Was this translation helpful? Give feedback.
-
|
#4176 不太影响业务，因为 EventSource 会忽略不符合 SSE 格式规范的数据行。 |
Beta Was this translation helpful? Give feedback.
-
|
谢谢您为我解答！可算是知道了问题所在。 |
Beta Was this translation helpful? Give feedback.
大概知道原因了，在第一次数据传输时，发送了一个{data: ' :ok'} 对象，这个逻辑参考了社区库的实现，有点问题，正确的应该拿到
才对