-
Notifications
You must be signed in to change notification settings - Fork 38
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: 支持websocket #2494 #2514
base: master
Are you sure you want to change the base?
feat: 支持websocket #2494 #2514
Conversation
71d3931
to
06fe8fb
Compare
} | ||
|
||
override fun registerStompEndpoints(registry: StompEndpointRegistry) { | ||
registry.addEndpoint(USER_ENDPOINT, APP_ENDPOINT) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
这里为什么要setAllowedOriginPatterns
两次
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
是两个不同的endpoint,需要单独设置
...bsocket/biz-websocket/src/main/kotlin/com/tencent/bkrepo/websocket/handler/SessionHandler.kt
Show resolved
Hide resolved
17f5be0
to
ef2e5ba
Compare
logger.warn("this session[$sessionId] already in cacheSession") | ||
return | ||
} | ||
cacheSessionList.add(sessionId) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
这边contains
与add
两个操作在并发执行时会不会导致重复添加
94a2dd7
to
098afd9
Compare
No description provided.