BEX5内使用websocket实现前端数据实时同步

1 set JRE_HOME=..\..\java\jre1.8
2 set JAVA_HOME=
3 set CATALINA_BASE=..\..\apache-tomcat
4 set PATH=%JRE_HOME%\bin;%PATH%

[JPivot] 13 六月 2016 17:29:26,072 ERROR [Session ] com.tonbeller.tbutils.res.JNDIResourceProvider#close: error closing context
javax.naming.OperationNotSupportedException: Context is read only
    at org.apache.naming.NamingContext.checkWritable(NamingContext.java:961)
    at org.apache.naming.NamingContext.close(NamingContext.java:761)
    at com.tonbeller.tbutils.res.JNDIResourceProvider.close(JNDIResourceProvider.java:68)
    at com.tonbeller.tbutils.res.CompositeResourceProvider.close(CompositeResourceProvider.java:56)
    at com.tonbeller.tbutils.res.ResourcesFactory.initialize(ResourcesFactory.java:163)
    at com.tonbeller.tbutils.res.ResourcesFactory.<init>(ResourcesFactory.java:92)
    at com.tonbeller.tbutils.res.ResourcesFactory.<clinit>(ResourcesFactory.java:89)
    at com.tonbeller.tbutils.res.ResourcesFactoryContextListener.contextInitialized(ResourcesFactoryContextListener.java:23)
    at org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:5068)
    at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5584)
    at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:147)
    at org.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:899)
    at org.apache.catalina.core.ContainerBase.addChild(ContainerBase.java:875)
    at org.apache.catalina.core.StandardHost.addChild(StandardHost.java:652)
    at org.apache.catalina.startup.HostConfig.deployDescriptor(HostConfig.java:679)
    at org.apache.catalina.startup.HostConfig$DeployDescriptor.run(HostConfig.java:1966)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)

tbeller.usejndi=false

Mixed Content: The page at ‘https://xxx‘ was loaded over HTTPS, but attempted to connect to the insecure WebSocket endpoint ‘ws://xxx/websocket/?rid=18‘. 
This request has been blocked; this endpoint must be available over WSS.

header(‘Content-Security-Policy: connect-src *;‘);

 <Connector port="443" protocol="org.apache.coyote.http11.Http11AprProtocol"
               maxThreads="150" SSLEnabled="true"  URIEncoding="UTF-8">
        <UpgradeProtocol className="org.apache.coyote.http2.Http2Protocol" />
        <SSLHostConfig>
            <Certificate certificateKeyFile="C:/Users/Administrator/AppData/Roaming/letsencrypt-win-simple/httpsacme-v01.api.letsencrypt.org/zcit2018.cn-key.pem"
                         certificateFile="C:/Users/Administrator/AppData/Roaming/letsencrypt-win-simple/httpsacme-v01.api.letsencrypt.org/zcit2018.cn-crt.pem"
                         certificateChainFile="C:/Users/Administrator/AppData/Roaming/letsencrypt-win-simple/httpsacme-v01.api.letsencrypt.org/zcit2018.cn-chain.pem"
                         type="RSA" />
        </SSLHostConfig>
    </Connector>

 1 package com.zc.websocket;
 2 
 3 import java.io.IOException;
 4 import java.util.HashMap;
 5 import java.util.Map;
 6 import java.util.concurrent.CopyOnWriteArraySet;
 7 
 8 import javax.websocket.OnClose;
 9 import javax.websocket.OnOpen;
10 import javax.websocket.Session;
11 import javax.websocket.server.ServerEndpoint;
12 
13 
14 @ServerEndpoint("/listener")
15 public class Listener {
16     
17     private static int onlineCount = 0;
18     
19     private static Map<String,CopyOnWriteArraySet<Listener>> webSocketMap = new HashMap<String,CopyOnWriteArraySet<Listener>>();
20     
21     private String fEventID = null;
22     
23     //与某个客户端的连接会话，需要通过它来给客户端发送数据
24     private Session session;
25     
26     
27     public static CopyOnWriteArraySet<Listener> getwebSocketSet(String fEventID){
28         
29         return Listener.webSocketMap.get(fEventID);
30     }
31      
32     /**
33      * 连接建立成功调用的方法
34      * 
35      * @param session 可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据
36      * 
37      */
38     @OnOpen
39     public void onOpen(Session session) {
40         this.session = session;
41         
42         this.fEventID = session.getRequestParameterMap().get("fEventID").get(0);
43         
44         CopyOnWriteArraySet<Listener> socekts = webSocketMap.get(this.fEventID);
45         if(socekts==null){ 
46             socekts = new CopyOnWriteArraySet<Listener>();
47             webSocketMap.put(this.fEventID,socekts); 
48         }
49         
50         socekts.add(this);
51         
52         addOnlineCount();   
53         System.out.println("有新监听加入！当前监听数为" + getOnlineCount());
54     }
55     
56     /**
57      * 连接关闭调用的方法
58      */
59     @OnClose
60     public void onClose() {
61         
62         webSocketMap.get(this.fEventID).remove(this);
63         
64         
65          subOnlineCount();
66          System.out.println("有一监听关闭！当前监听数为" + getOnlineCount());
67     }
68     
69     /**
70      * 这个方法与上面几个方法不一样。没有用注解，是根据自己需要添加的方法。
71      * 
72      * @param message
73      * @throws IOException
74      */
75     public void sendMessage(String message) throws IOException {
76         this.session.getBasicRemote().sendText(message);
77     }
78     
79     
80      public static synchronized int getOnlineCount() {
81                  return onlineCount;
82             }
83         
84              public static synchronized void addOnlineCount() {
85                  Listener.onlineCount++;
86             }
87          
88             public static synchronized void subOnlineCount() {
89                 Listener.onlineCount--;
90      }
91     
92 }

package com.zc.websocket;

import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;

import javax.websocket.OnMessage;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

import com.alibaba.fastjson.JSONObject;


@ServerEndpoint("/notifier")
public class Notifier {
    
    
    /**
     * 收到客户端消息后调用的方法
     * 
     * @param message
     *            客户端发送过来的消息
     * @param session
     *            可选的参数
     */
    @OnMessage
    public void onMessage(String message, Session session) {
        
        System.out.print("有新的通知："+message);
        
        
        JSONObject values = JSONObject.parseObject(message);
        
        CopyOnWriteArraySet<Listener> websocketSet = Listener.getwebSocketSet(values.getString("fEventID"));
        
        if(websocketSet==null){
            System.out.println(" 监听数量：0");
            return;
        }else{
            System.out.println(" 监听数量："+websocketSet.size());
        }
        
        // 群发消息
        for (Listener item : websocketSet) {
            try {
                item.sendMessage(values.getString("message"));
            } catch (IOException e) {
                e.printStackTrace();
                continue;
            }
        }
    }
    
}

define(function(require) {
    
    var Model = function() {
        this.callParent();
    };
    
    var URI = "wss://zcit2018.cn";
//    var URI = "ws://baxd.ys100.com:8999";
    
    var err = {
        "type":"连接失败",
        "URI":URI,
        "address":"/UI2/B/M000_Core/process/Utils/WebSocketUtils.js"
    };
    
    /**
     * 注册一个fEventID的消息接收监听
     * @param fEventID 监听标识
     * @params callback 回调函数，带参数
     * @returns websocket对象
     */
    Model.setListener = function(fEventID,callback){
        if(!fEventID){
            throw "fEventID 不能为空!";
        }
        
        var websocket = null;
        
        //判断当前浏览器是否支持WebSocket
        if (‘WebSocket‘ in window) {
            try{
            websocket = new WebSocket(URI+"/ZCServer/listener?fEventID="+fEventID);
            }catch(e){
                console.log(err);
                return false;
            }
        } else {
            console.log(‘当前浏览器 Not support websocket‘);
            return false;
        }
        //连接发生错误的回调方法
        websocket.onerror = function() {
            
            console.log(err);
            
        };
        
        //连接成功建立的回调方法
        websocket.onopen = function() {};
        //接收到消息的回调方法
        websocket.onmessage = function(event) {
            if(callback&& typeof callback =="function"){
                callback(event);
            }
        };
        
        //连接关闭的回调方法
        websocket.onclose = function() {};
        
        return websocket;
    };    
    
    /**
     * 给fEventIDs发送通知message
     * @params fEventIDs 监听者IDs数组
     * @params message 消息内容
     * 
     */
    Model.sendNotic = function(fEventIDs,message){
        if(!Array.isArray(fEventIDs)){
            throw "fEventIDs 必须为数组!";
        }
        
        var websocket = null;
        
        //判断当前浏览器是否支持WebSocket
        if (‘WebSocket‘ in window) {
            try{
                websocket = new WebSocket(URI+"/ZCServer/notifier");
            }catch(e){
                console.log(err);
                return false;
            }
        } else {
            console.log(‘当前浏览器 Not support websocket‘);
            return false;
        }
        
        

        websocket.onopen = function() {

            for ( var i in fEventIDs) {
                websocket.send(JSON.stringify({
                    "fEventID" : fEventIDs[i],
                    "message" : message?message:""
                }));
            }
            websocket.close();
        };
        
        
    };
    

    return Model;
});

1 websocket.setListener("10e0495c-650c-486a-8d65-552f103aa243",function(re){
2      // 处理逻辑
3  });

websocket.sendNotic([‘10e0495c-650c-486a-8d65-552f103aa243‘],message);