使用tomcat方式实现websocket即时通讯服务端讲解-创新互联

使用tomcat方式实现websocket即时通讯服务端讲解

第一种方案：使用Tomcat的方式实现

tomcat版本要求：tomcat7.0+。需要支持Javaee7

导入javeee-api的jar(如果已经引入可以忽略):

pom.xml中加入：

javax

javaee-api

7.0

provided

一：几个重要的注解(方法)：

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许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。