SpringBoot的WebSocket初体验- -

客官°小女子只卖身不卖艺 2022-05-20 01:46 196阅读 0赞

引自[我的gitbook][gitbook]：

##  ##

1.POM配置

< dependency >

< groupId > org.springframework.boot </ groupId >

< artifactId > spring-boot-starter-websocket </ artifactId >

< exclusions >

< exclusion >

< groupId > org.springframework.boot </ groupId >

< artifactId > spring-boot-starter-tomcat </ artifactId >

</ exclusion >

</ exclusions >

</ dependency >

< dependency >

< groupId > org.springframework.boot </ groupId >

< artifactId > spring-boot-starter-undertow </ artifactId >

</ dependency >

</ dependencies >

##  ##

2.下面是直接搭建服务器。。

package  cn . zhenyang . socket . server . controller . socket ;

import  cn . zhenyang . socket . server . config . GetHttpSessionConfigurator ;

import  cn . zhenyang . socket . server . config . ServerDecoder ;

import  cn . zhenyang . socket . server . config . ServerEncoder ;

import  cn . zhenyang . socket . server . constant . Params ;

import  org . springframework . stereotype . Component ;

import  org . springframework . web . context . request . RequestContextHolder ;

import  org . springframework . web . context . request . ServletRequestAttributes ;

import  javax . servlet . http . HttpServletRequest ;

import  javax . servlet . http . HttpSession ;

import  javax . websocket . \* ;

import  javax . websocket . server . ServerEndpoint ;

import  java . io . IOException ;

import  java . util . concurrent . CopyOnWriteArraySet ;

/\*\*

\* @Author ZhenYang

\* @Date Created in 2018/2/19 3:58

\* @Description

\*/

@ServerEndpoint ( value  =  "/websocket" , configurator  =  GetHttpSessionConfigurator . class /\*,decoders = ServerDecoder.class,encoders = ServerEncoder.class\*/ )

@Component

public  class  WebSocketServer  \{

//静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。

public  static  int  onlineCount  =  0 ;

//concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。

public  static  CopyOnWriteArraySet < WebSocketServer >  webSocketSet  =  new  CopyOnWriteArraySet < WebSocketServer > ( ) ;

//与某个客户端的连接会话，需要通过它来给客户端发送数据

public  Session session ;

/\*\*

\* 连接建立成功调用的方法

\*/

@OnOpen

public  void  onOpen ( Session session , EndpointConfig config )  \{

this . session  =  session ;

System . out . println ( "the session is : " \+ session . getId ( ) ) ;

System . out . println ( "session content is : " \+ session . getId ( ) ) ;

webSocketSet . add ( this ) ;  //加入set中

addOnlineCount ( ) ;  //在线数加1

System . out . println ( "有新连接加入！当前在线人数为"  \+  getOnlineCount ( ) ) ;

// ServletActionContext servletActionContext ;

try  \{

//sendMessage(CommonConstant.CURRENT\_WANGING\_NUMBER.toString());

// System.out.println(Params.httpSession.getAttribute("xxx"));

sendMessage ( "22222222" ) ;

\}  catch  ( IOException  e )  \{

System . out . println ( "IO异常" ) ;

/\*\*

\* 连接关闭调用的方法

\*/

@OnClose

public  void  onClose ( )  \{

System . out . println ( this . session . getId ( ) \+ ":这个断开" ) ;

webSocketSet . remove ( this ) ;  //从set中删除

subOnlineCount ( ) ;  //在线数减1

System . out . println ( "有一连接关闭！当前在线人数为"  \+  getOnlineCount ( ) ) ;

/\*\*

\* 收到客户端消息后调用的方法

\* @param message 客户端发送过来的消息

\*/

@OnMessage

public  void  onMessage ( String message ,  Session session )  \{

// HttpServletRequest request =

// System.out.println(httpSession.getAttribute("xxx"));

System . out . println ( "来自客户端的消息:"  \+  message ) ;

System . out . println ( "onMessage sessionId is : " \+ session . getId ( ) ) ;

//群发消息

for  ( WebSocketServer item  :  webSocketSet )  \{

try  \{

item . sendMessage ( message ) ;

\}  catch  ( IOException  e )  \{

e . printStackTrace ( ) ;

/\*\*

\* 发生错误时调用

\*/

@OnError

public  void  onError ( Session session ,  Throwable error )  \{

System . out . println ( error . getMessage ( ) ) ;

/\*\*

\* 给当前用户发送消息

\* @param message

\* @throws IOException

\*/

public  void  sendMessage ( String message )  throws  IOException  \{

System . out . println ( Params . httpSession . getAttribute ( "xxx" ) ) ;

this . session . getBasicRemote ( ) . sendText ( message \+ " : sendMessage id is : " \+ this . session . getId ( ) ) ;

//this.session.getAsyncRemote().sendText(message);

/\*\*

\* 群发自定义消息

\*/

public  static  void  sendInfo ( String message )  throws  IOException  \{

for  ( WebSocketServer item  :  webSocketSet )  \{

try  \{

item . sendMessage ( message ) ;

\}  catch  ( IOException  e )  \{

continue ;

public  static  synchronized  int  getOnlineCount ( )  \{

return  onlineCount ;

public  static  synchronized  void  addOnlineCount ( )  \{

WebSocketServer . onlineCount \++ ;

public  static  synchronized  void  subOnlineCount ( )  \{

WebSocketServer . onlineCount \-- ;

另声明了一个静态会话。

public static HttpSession httpSession;

SpringBoot的WebSocket初体验- -

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 SpringBoot初体验之整合SpringMVC

相关【SpringBoot】SSM“加速器”SpringBoot初体验

相关 SpringBoot：Gateway引入初体验

相关 rocketmq初体验

相关 springboot初体验

相关 springboot初体验

相关 SpringBoot的WebSocket初体验- -

相关 Docker的初体验

相关 Gitbook初体验

相关 SpringBoot+SpringSecurity+jwt整合及初体验