webSocket.js 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. import WebsocketHeartbeat from "./WebsocketHeartbeat";
  2. var server = "";
  3. var aServer="";
  4. if (process.env.NODE_ENV === 'development') {
  5. server = "ws://localhost:7018/imserver/r:";
  6. aServer = "ws://localhost:7018/imserver/u:";
  7. }else{
  8. server = "wss://im.yjf.runtzh.com/imserver/r:";
  9. aServer = "wss://im.yjf.runtzh.com/imserver/u:";
  10. //server = "ws://139.186.77.83:7018/imserver/r:";
  11. }
  12. export default {
  13. socket: {},
  14. aSoket:{},
  15. hasLogin:false,
  16. initSocket: function(uid,reset) {
  17. if(typeof(WebSocket) === "undefined"){
  18. console.log("您的浏览器不支持socket")
  19. }else{
  20. // 实例化socket
  21. if(!this.socket || reset){
  22. console.log("实例化socket");
  23. return
  24. //this.socket = new WebSocket(server+uid);
  25. this.socket=new WebsocketHeartbeat({
  26. url: server+uid,
  27. userId:"r:"+uid,
  28. pingTimeout: 15000,
  29. pongTimeout: 10000
  30. });
  31. // this.socket.onopen = function () {
  32. // console.log('connect success');
  33. // console.log('send massage: test');
  34. // websocketHeartbeatJs.send('test');
  35. // setTimeout(() => {
  36. // console.log(`wait ${websocketHeartbeatJs.opts.pingTimeout} ms will hava '${websocketHeartbeatJs.opts.pingMsg}'`);
  37. // }, 1500);
  38. // }
  39. this.hasLogin=true;
  40. }
  41. }
  42. },
  43. initASocket: function(uid,reset,that) {
  44. if(typeof(WebSocket) === "undefined"){
  45. that.$notify.error({
  46. title: '您的浏览器不支持socket',
  47. showClose: false
  48. });
  49. console.log("您的浏览器不支持socket")
  50. }else{
  51. return
  52. // 实例化socket
  53. if(!this.aSoket || reset){
  54. console.log("实例化aSocket");
  55. this.aSoket=new WebsocketHeartbeat({
  56. url: aServer+uid,
  57. userId:"u:"+uid,
  58. pingTimeout: 15000,
  59. pongTimeout: 10000
  60. });
  61. }
  62. }
  63. }
  64. }