require(["jquery", "ipu-stomp"], function($, IpuStomp) {
  //	var baseUrl = "ws://localhost:7100/stomp";
    var baseUrl = "ws://47.105.160.21:7100/stomp";
    var login = "empty_account1";
    var passcode = "123456";
    var host = "";
  
    var client;
    //为发送者input绑定onchange事件
    $("#userId").on("change", function(e) {
      $("#userId").val(e.target.value);
    })
    
    var callbacks = {};
    callbacks.onConnected = function(msg){
      console.log("连接成功：" + msg);
      alert("连接成功：" + msg);
      $("#connBtn").val("断开连接");
      $("#connBtn").attr("id", "disconnBtn");
      $("#userId").attr("disabled", "disabled");
    }
      callbacks.onFailure = function(msg){
      console.log("连接失败：" + msg);
      alert("连接失败：" + msg);
    }
  
    $("#connBtn").on("click", function(e) {
      if (typeof (WebSocket) == "undefined") {
        console.log("您的浏览器不支持WebSocket");
      } else {
        console.log("您的浏览器支持WebSocket");
        //实例化WebSocket对象，指定要连接的服务器地址与端口  建立连接
        //等同于socket = new WebSocket("ws://localhost:8888/xxxx/im/25");
        if (!client || !client.connected()) {
          //检查用户ID
          if (!$("#userId").val()) {
            alert("请填写用户名")
            return;
          }
          client = IpuStomp.connect({url:baseUrl,name:login,passcode:passcode,host:host}, callbacks);
          client.setTopicPath("topic");
          
        } else {
          client.disconnect();
          subscription && subscription.unsubscribe();
          $("#disconnBtn").val("连接服务器");
          $("#disconnBtn").attr("id", "connBtn");
          $("#userId").removeAttr("disabled");
        }
      }
    });
    var subscription;
    var path = [
    ];
    $("#receBtn").on(
			"click",
			function(e) {
				console.log(subscription)
				if (subscription) {
					//如果已经订阅
					$("#receBtn").val("订阅");
					$("#receTopic").removeAttr("disabled");
					subscription.unsubscribe();
					subscription = null;
				} else {

					//校验连接状态
					if (!client || !client.connected()) {
						alert("服务未连接")
						return;
					}

					//校验订阅频道
					if (!$("#receTopic").val()) {
						alert("请填写订阅频道")
						return;
					}
					//订阅一个目的地
					//STOMP消息的body必须为字符串
					subscription = client.subscribe($("#receTopic").val(), function(msg) {
            //发现消息进入，开始处理前端触发逻辑
            console.log(msg.body)
						console.log(JSON.parse(msg.body))
						var msgObj = JSON.parse(msg.body)
						var newMsg = new Date().toLocaleString() + "\n"
								+ msgObj.userId + " : " + msgObj.contentText
            var oldMsg = $("#contentText").val()
            console.log(msgObj.contentText)
            var img = new Image();
            $(img).bind("load", function () {
              $("#canvas img").attr("src", this.src);
            });
           img.src = msgObj.contentText;
            // $("#canvas img").attr("src", msgObj.contentText);
					});
					$("#receBtn").val("取消订阅");
					$("#receTopic").attr("disabled", "disabled");
				}
			})
  
   
  });