本文实例为大家分享了java与微信小程序实现websocket长连接的具体代码，供大家参考，具体内容如下

背景：

需要在小程序实现地图固定坐标下实时查看消息

java环境 :tomcat7 jdk1.7

1.java

websocket 类

package com.qs.util;

import java.io.bufferedreader;

import java.io.ioexception;

import java.io.inputstreamreader;

import java.io.printwriter;

import java.net.httpurlconnection;

import java.net.url;

import java.util.concurrent.copyonwritearrayset;

import javax.websocket.*;

import javax.websocket.server.serverendpoint;

import com.qs.controller.usercontroller;

/**

* @serverendpoint 注解是一个类层次的注解，它的功能主要是将目前的类定义成一个websocket服务器端,

* 注解的值将被用于监听用户连接的终端访问url地址,客户端可以通过这个url来连接到websocket服务器端

*/

@serverendpoint("/websocket")

public class websockettest {

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

private static int onlinecount = 0;

//concurrent包的线程安全set，用来存放每个客户端对应的mywebsocket对象。若要实现服务端与单一客户端通信的话，可以使用map来存放，其中key可以为用户标识

private static copyonwritearrayset websocketset = new copyonwritearrayset();

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

private session session;

/**

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

* @param session 可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据

*/

@onopen

public void onopen(session session){

this.session = session;

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

addonlinecount(); //在线数加1

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

}

/**

* 连接关闭调用的方法

*/

@onclose

public void onclose(){

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

subonlinecount(); //在线数减1

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

}

/**

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

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

* @param session 可选的参数

*/

@onmessage

public void onmessage(string message, session session) {

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

//群发消息

for(websockettest item: websocketset){

try {

item.sendmessage(message);

} catch (ioexception e) {

e.printstacktrace();

continue;

}

}

}

/**

* 发生错误时调用

* @param session

* @param error

*/

@onerror

public void onerror(session session, throwable error){

system.out.println("发生错误");

error.printstacktrace();

}

/**

* 这个方法与上面几个方法不一样。没有用注解，是根据自己需要添加的方法。

* @param message

* @throws ioexception

*/

public void sendmessage(string message) throws ioexception{

this.session.getbasicremote().sendtext(message);

//this.session.getasyncremote().sendtext(message);

}

public static synchronized int getonlinecount() {

return onlinecount;

}

public static synchronized void addonlinecount() {

websockettest.onlinecount++;

}

public static synchronized void subonlinecount() {

websockettest.onlinecount--;

}

}

2. jsp

java后端websocket的tomcat实现

welcome

发送消息

---

关闭websocket连接

---

var websocket = null;

//判断当前浏览器是否支持websocket

if ('websocket' in window) {

websocket = new websocket("ws://image.aropen.com/image-retrievals/websocket");

}

else {

alert('当前浏览器 not support websocket')

}

//连接发生错误的回调方法

websocket.onerror = function () {

setmessageinnerhtml("websocket连接发生错误");

};

//连接成功建立的回调方法

websocket.onopen = function () {

setmessageinnerhtml("websocket连接成功");

}

//接收到消息的回调方法

websocket.onmessage = function (event) {

setmessageinnerhtml(event.data);

}

//连接关闭的回调方法

websocket.onclose = function () {

setmessageinnerhtml("websocket连接关闭");

}

//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。

window.onbeforeunload = function () {

closewebsocket();

}

//将消息显示在网页上

function setmessageinnerhtml(innerhtml) {

document.getelementbyid('message').innerhtml += innerhtml + '
';

}

//关闭websocket连接

function closewebsocket() {

websocket.close();

}

//发送消息

function send() {

var message = document.getelementbyid('text').value;

var arr=['zhangsan,hello,1','lisi,word,1','wangwu,hi,1','zhaoliu,hehe,1','tianqi,haha,1'];

window.setinterval(function(){

websocket.send(arr[math.floor(math.random()*4)]);

},5000);

//websocket.send(message);

}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持萬仟网。

如您对本文有疑问或者有任何想说的，请点击进行留言回复，万千网友为您解惑！