webSocket.js 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  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. //this.socket = new WebSocket(server+uid);
  24. this.socket=new WebsocketHeartbeat({
  25. url: server+uid,
  26. userId:"r:"+uid,
  27. pingTimeout: 15000,
  28. pongTimeout: 10000
  29. });
  30. // this.socket.onopen = function () {
  31. // console.log('connect success');
  32. // console.log('send massage: test');
  33. // websocketHeartbeatJs.send('test');
  34. // setTimeout(() => {
  35. // console.log(`wait ${websocketHeartbeatJs.opts.pingTimeout} ms will hava '${websocketHeartbeatJs.opts.pingMsg}'`);
  36. // }, 1500);
  37. // }
  38. this.hasLogin=true;
  39. }
  40. }
  41. },
  42. initASocket: function(uid,reset,that) {
  43. if(typeof(WebSocket) === "undefined"){
  44. that.$notify.error({
  45. title: '您的浏览器不支持socket',
  46. showClose: false
  47. });
  48. console.log("您的浏览器不支持socket")
  49. }else{
  50. // 实例化socket
  51. if(!this.aSoket || reset){
  52. console.log("实例化aSocket");
  53. this.aSoket=new WebsocketHeartbeat({
  54. url: aServer+uid,
  55. userId:"u:"+uid,
  56. pingTimeout: 15000,
  57. pongTimeout: 10000
  58. });
  59. }
  60. }
  61. }
  62. }