javascript - 微信小程序websocket java获取不到data-PHP中国語ネットワークQ&A

在使用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<MyWebSocket> webSocketSet = new CopyOnWriteArraySet<MyWebSocket>();
    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("<p><span style='color:#ff0000;'>我说："+message+"</span>  <span style='color:#bbbaba;'>当前在线人数："+getOnlineCount()+"</span></p>");
                    item.sendMessage(message);
                }else{
                    item.sendMessage("<p>"+message+"  当前在线人数："+getOnlineCount()+"</p>");
                }

            }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<Map.Entry<String,WebSocketSession>> it = userSocketSessionMap
                .entrySet().iterator();
        //多线程群发
        while(it.hasNext()){
            final Map.Entry<String,WebSocketSession> 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就是空的了。