使用tomcat方式实现websocket即时通讯服务端讲解
成都创新互联公司"三网合一"的企业建站思路。企业可建设拥有电脑版、微信版、手机版的企业网站。实现跨屏营销,产品发布一步更新,电脑网络+移动网络一网打尽,满足企业的营销需求!成都创新互联公司具备承接各种类型的成都网站设计、网站建设项目的能力。经过10余年的努力的开拓,为不同行业的企事业单位提供了优质的服务,并获得了客户的一致好评。第一种方案:使用Tomcat的方式实现
tomcat版本要求:tomcat7.0+。需要支持Javaee7
导入javeee-api的jar(如果已经引入可以忽略):
pom.xml中加入:
一:几个重要的注解(方法):
1.1:@ServerEndpoin():
声明这是一个websocket服务;
需要指定访问该服务的地址。
在地址中可以指定参数,需要使用{}进行占位。
注解使用位置:类上面
示例:
@ServerEndpoin("/websocket/{userId}")
public class myTest(){
}
1.2:@OnOpen:
该方法将在建立连接后执行,会传入session对象;
可以通过@PathParam来获取url声明中参数
注解使用位置:方法中
用法示例:
public void onOpen(Session session,@PathParam("userId") Integer userId) throws IOExcepthon{}
1.3:@OnClose:
该方法是在连接关闭后执行的
注解位置:方法上
使用示例:
public void onClose(){}
1.4:@OnMessage:
该方法用于接收客户端发来的消息
参数:
message:发来的消息数据
session:会话对象(也即是通道)
注解位置:方法
示例用法:
public void onMessage(String message,Session session) throws IOException{}
1.5:@OnError:
出错的时候访问的。
注解位置:方法上
使用示例:
public void onError(Session session,Throwable error){}
1.6:给客户端返回消息(或是给客户端发送消息):
使用session对象的getBasinRemoter().sendTest()方法
用法示例:
session.getBasicRemoter().sendText("您发送的消息已经收到了");
二:根据上面几个重要方法,编写客户端代码:
@OnOpen
public void onOpen(Session session, @PathParam("userName") String userName) throws IOException {
log.info("=== 打开连接了===");
session.getBasicRemote().sendText("欢迎:"+userName+"访问系统");
}
@OnMessage
public void onMessage(String message,Session session, @PathParam("userName") String userName) throws IOException {
log.info("==接收到客户端发来的消息是:{}",message);
session.getBasicRemote().sendText("您好:"+userName+" 您发送的消息"+message+",系统已经收到....");
}
访问效果:
说明:websocket访问的协议是ws://而非http://
上图中:橙色的是我发送的,下面对应的就是系统返回的。
查看服务器日志打印:
我们可以看到,通信已经建立了。代码已经放在git上了。欢迎大家一起学习。
下节预告:下节我们将使用spring框架来整合websocket的
另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。