在使用java作为后台测试微信小程序时，发现：

1.后台中ServerHttpRequest request中的session是空的，前端通过wx.connectSocket传递的data也没看到。

2.可以从前端网后台传递信息，但是后台往前端发送时会报出如下错误

有没有大神能告知下解决方案呢？

Java后台实现WebSocket时一共尝试了两种方案，一种是java+spring，一种是纯spring的，而且两者都会出现上面的情况，同时

其中：

springMVC时报如下错误：

Exception in thread "Thread-21" java.lang.IllegalStateException: The remote endpoint was in state [STREAM_WRITING] which is an invalid state for called method

at org.apache.tomcat.websocket.WsRemoteEndpointImplBase$StateMachine.checkState(WsRemoteEndpointImplBase.java:1225)

at org.apache.tomcat.websocket.WsRemoteEndpointImplBase$StateMachine.textPartialStart(WsRemoteEndpointImplBase.java:1182)

at org.apache.tomcat.websocket.WsRemoteEndpointImplBase.sendPartialString(WsRemoteEndpointImplBase.java:222)

at org.apache.tomcat.websocket.WsRemoteEndpointBasic.sendText(WsRemoteEndpointBasic.java:49)

at org.springframework.web.socket.adapter.standard.StandardWebSocketSession.sendTextMessage(StandardWebSocketSession.java:197)

at org.springframework.web.socket.adapter.AbstractWebSocketSession.sendMessage(AbstractWebSocketSession.java:104)

at cn.zhonya.WXTalkDome.webSocket.MyWebSocketHandler$1.run(MyWebSocketHandler.java:139)

at java.lang.Thread.run(Thread.java:745)

java+spring时会报如下错误：

java.lang.IllegalStateException: The remote endpoint was in state [WRITER_WRITING] which is an invalid state for called method

at org.apache.tomcat.websocket.WsRemoteEndpointImplBase$StateMachine.checkState(WsRemoteEndpointImplBase.java:1225)

at org.apache.tomcat.websocket.WsRemoteEndpointImplBase$StateMachine.textStart(WsRemoteEndpointImplBase.java:1187)

at org.apache.tomcat.websocket.WsRemoteEndpointImplBase.sendString(WsRemoteEndpointImplBase.java:190)

at org.apache.tomcat.websocket.WsRemoteEndpointBasic.sendText(WsRemoteEndpointBasic.java:37)

at cn.zhonya.WXTalkDome.webSocket.MyWebSocket.sendMessage(MyWebSocket.java:107)

at cn.zhonya.WXTalkDome.webSocket.MyWebSocket.onMessage(MyWebSocket.java:80)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at java.lang.reflect.Method.invoke(Method.java:498)

at org.apache.tomcat.websocket.pojo.PojoMessageHandlerWholeBase.onMessage(PojoMessageHandlerWholeBase.java:80)

at org.apache.tomcat.websocket.WsFrameBase.sendMessageText(WsFrameBase.java:399)

at org.apache.tomcat.websocket.server.WsFrameServer.sendMessageText(WsFrameServer.java:106)

at org.apache.tomcat.websocket.WsFrameBase.processDataText(WsFrameBase.java:500)

at org.apache.tomcat.websocket.WsFrameBase.processData(WsFrameBase.java:295)

at org.apache.tomcat.websocket.WsFrameBase.processInputBuffer(WsFrameBase.java:131)

at org.apache.tomcat.websocket.server.WsFrameServer.onDataAvailable(WsFrameServer.java:69)

at org.apache.tomcat.websocket.server.WsHttpUpgradeHandler.upgradeDispatch(WsHttpUpgradeHandler.java:148)

at org.apache.coyote.http11.upgrade.UpgradeProcessorInternal.dispatch(UpgradeProcessorInternal.java:54)

at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:53)

at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:785)

at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1419)

at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:44)

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)

at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)

at java.lang.Thread.run(Thread.java:745)

java+spring的socket代码如下：

@ServerEndpoint(value = "/websocket2.do",configurator = SpringConfigurator.class)

public class MyWebSocket {

private static int onlineCount = 0;

public MyWebSocket(){

}

@Autowired

private static CopyOnWriteArraySet webSocketSet = new CopyOnWriteArraySet();

private static Logger logger = Logger.getLogger(MyWebSocket.class);

private Session session;

/**

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

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

*/

@OnOpen

public void onOpen(Session session, @PathParam("user") String user,@PathParam("uid") String uid){

this.session = session;

// session.getAttributes();

logger.info("——————————————");

logger.info("——————————————");

logger.info("——————————————");

logger.info("——————————————");

JSONObject s = new JSONObject(session);

String str= session.getQueryString();

String [] strs = str.split("&");

int slen = strs.length;

for(String quey:strs){

String [] q = quey.split("=");

System.out.println("sing:"+q[0]+" value:"+q[1]);

}

logger.info("webSocketSet————————："+s.toString());

logger.info("——————————————");

logger.info("——————————————");

logger.info("——————————————");

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

addOnlineCount();//在线人数加1

System.out.println("有新链接加入！当前在线人数为："+getOnlineCount()+" user:"+user+" uid:"+uid);

}

/**

* 连接关闭调用的方法

*/

@OnClose

public void onClose(){

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

subOnlineCount();

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

}

@OnMessage

public void onMessage(String message,Session session){

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

//群发消息

for(MyWebSocket item:webSocketSet){

try{

if(item.session == session){

// item.sendMessage("

我说："+message+" 当前在线人数："+getOnlineCount()+"

");

item.sendMessage(message);

}else{

item.sendMessage("

"+message+" 当前在线人数："+getOnlineCount()+"

");

}

}catch (IOException e){

e.printStackTrace();

continue;

}

}

}

@OnError

public void onError(Session session,Throwable error){

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

error.printStackTrace();

}

/**

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

* @param message

*/

private void sendMessage(String message) throws IOException {

//保存到数据库

// Content content = new Content();

// content.setContent(message);

// content.setCreateDate(StringUtilZ.getTimestampOfNow("yyyy-MM-dd HH:mm:ss"));

this.session.getBasicRemote().sendText(message);

}

public static synchronized int getOnlineCount(){

return onlineCount;

}

public static synchronized void addOnlineCount() {

MyWebSocket.onlineCount++;

}

private static synchronized void subOnlineCount(){

MyWebSocket.onlineCount--;

}

}

springmvc自身的那个文件比较多就不多贴了，暂时贴下那个139行上下的内容

public void broadcast(final TextMessage message)throws IOException {

Iterator> it = userSocketSessionMap

.entrySet().iterator();

//多线程群发

while(it.hasNext()){

final Map.Entry entry = it.next();

if(entry.getValue().isOpen()){

new Thread(new Runnable() {

public void run() {

try{

if(entry.getValue().isOpen()){

entry.getValue().sendMessage(message);

}

} catch (IOException e){

e.printStackTrace();

}

}

}).start();

}

}

}

这两种方法在普通WebSocket中都没问题，换到微信小程序就只能接受客户端消息，没办法将消息从服务器传到客户端。怀疑是不是那个session的问题啊，在小程序中使用获取到的session就是空的了。