sendMsg() {

    //新建连接

     var ws = new $WebSocket("具体地址");

    //打开连接

     ws.onOpen(function () {

       console.log('连接成功')

         ws.send('发送的消息内容').subscribe(

           (msg) => {

           //连接成功此处打印成功的提示

             console.log("next", msg.data);

           },

           (msg) => {

            //连接失败则打印此信息

             console.log("error", msg);

           },

           () => {

             //不管有没有连接成功必须执行到此处

             console.log("complete");

             // 可在此处关闭连接，由你websocket实现的具体功能决定

             // ws.close(false);    // close

             // ws.close(true);    // close immediately

           }

         );

     });

    //接收服务器返回的信息就另外写个

     ws.onMessage(

       (msg: MessageEvent) => {

         console.log('recriveMsg',msg)

       },

       { autoApply: false }

     );

   }