socket.io - 如何将 socket.io 与 graphql 订阅一起使用?
问题描述
我想通过使用nestjs和graphql技术制作一个实时聊天应用程序。大多数教程都使用 PubSub,但我不知道如何向特定客户端发送消息(?)。我认为使用 socket.io 通过使用套接字 id 向特定客户端发送消息非常容易。
此示例使用 PubSub:
- 有没有办法使用 PubSub 向特定客户端发送消息?通过接收一些关于发件人的数据,比如 id。
- 如何用 Socket.io 替换 PubSub?我对 socket.io 非常满意
应用模块.ts
import { Module, MiddlewareConsumer, RequestMethod, Get } from '@nestjs/common';
import { TypeOrmModule } from '@nestjs/typeorm';
import { typeOrmConfig } from './config/typeorm.config';
import { AuthModule } from './auth/auth.module';
import { LoggerMiddleware } from './common/middlewares/logger.middleware';
import { Connection } from 'typeorm';
import { GraphQLModule } from '@nestjs/graphql';
import { join } from 'path';
import { ChatModule } from './chat/chat.module';
import { ChatService } from './chat/chat.service';
@Module({
imports: [
TypeOrmModule.forRoot(typeOrmConfig), // connect to database
GraphQLModule.forRoot({
debug: true,
playground: true,
typePaths: ['**/*.graphql'],
definitions: {
path: join(process.cwd(), 'src/graphql.ts'),
},
}),
AuthModule,
ChatModule,
],
controllers: [],
providers: [
],
})
export class AppModule {
}
聊天模块.ts
import { Module } from '@nestjs/common';
import { ChatService } from './chat.service';
import { ChatResolver } from './chat.resolver';
import { TypeOrmModule } from '@nestjs/typeorm';
import { AuthModule } from '../auth/auth.module';
import { PubSub } from 'graphql-subscriptions';
@Module({
imports: [
// Add all repository here; productRepository, ...
TypeOrmModule.forFeature( [
// repositories ...
]),
AuthModule
],
providers: [
//=> How to replace with socket.io ?
{
provide: 'PUB_SUB',
useValue: new PubSub(),
},
ChatService,
ChatResolver,
]
})
export class ChatModule {}
聊天解析器.ts
import { Resolver, Query, Mutation, Args, Subscription } from '@nestjs/graphql';
import { PubSubEngine } from 'graphql-subscriptions';
import { Inject } from '@nestjs/common';
const PONG_EVENT_NAME = 'pong';
@Resolver('Chat')
export class ChatResolver {
constructor(
private chatService: ChatService,
@Inject('PUB_SUB')
private pubSub: PubSubEngine,
) {}
// Ping Pong
@Mutation('ping')
async ping() {
const pingId = Date.now();
//=> How to send deta to specific client by using user-id?
this.pubSub.publish(PONG_EVENT_NAME, { ['pong']: { pingId } });
return { id: pingId };
}
@Subscription(PONG_EVENT_NAME)
pong() {
//=> how to get data about sender like id?
return this.pubSub.asyncIterator(PONG_EVENT_NAME);
}
}
聊天.graphql
type Mutation {
ping: Ping
}
type Subscription {
tagCreated: Tag
clientCreated: Client
pong: Pong
}
type Ping {
id: ID
}
type Pong {
pingId: ID
}
如何用 Socket.io 替换 PubSub?
解决方案
我没有找到任何解决方案或示例来从 graphql 订阅中获取客户端套接字。在大多数示例中,他们使用网关而不是 graphql pubsub。所以我使用 GateWay 来实现实时活动和 graphql 来处理其他请求。
推荐阅读
- java - 在 Java 8 中使用方法引用时出现编译错误
- android - 如何在@Entity 的 primaryKeys 列表中设置 autoGenerate?
- git - gitlab-ci 中的增量更新
- java - 如何在 CSV 中添加由 Java 中的数据组成的列
- r - R save() 不产生任何输出但没有错误
- php - Laravel 迁移:无法添加外键约束
- python - 与 Numpy Array 相比,Numpy 矩阵内存大小低
- google-app-maker - 如何暂停应用程序制造商部署?
- vba - VBA - 基于附件文件名移动电子邮件
- visual-studio - Unity - 如何开始处理大型地形/地图?