Integrate third-party applications

Beego supports to integrate third-party application, you can customize http.Handler as follows:

  1. beego.Handler("/chat/:info(.*)", sockjs.NewHandler("/chat", opt, YouHandlerFunc))

sockjshandler implemented interface http.Handler.

Beego has an example for supporting echo app of sockjs, here is the code:

  1. package main
  3. import (
  4.     "log"
  6.     "time"
  8.     "gopkg.in/igm/sockjs-go.v2/sockjs"
  9. )
  11. func LiveUpdate(session sockjs.Session) {
  12.     var closedSession = make(chan struct{})
  13.     reader := make(chan string)
  14.     go func() {
  15.         for {
  16.             reader <- "echo"
  17.             time.Sleep(time.Second)
  18.         }
  19.     }()
  20.     go func() {
  21.         for {
  22.             select {
  23.             case <-closedSession:
  24.                 return
  25.             case msg := <-reader:
  26.                 if err := session.Send(msg); err != nil {
  27.                     return
  28.                 }
  29.             }
  30.         }
  31.     }()
  32.     for {
  33.         if _, err := session.Recv(); err == nil {
  34.             continue
  35.         }
  36.         break
  37.     }
  38.     close(closedSession)
  39.     log.Println("sockjs session closed")
  40. }
  42. type MainController struct {
  43.     beego.Controller
  44. }
  46. func (m *MainController) Get() {
  47.     m.TplNames = "index.html"
  48. }
  50. func main() {
  51.     beego.Router("/", &MainController{})
  52.     beego.Handler("/chat/:info(.*)", sockjs.NewHandler("/chat", sockjs.DefaultOptions, YouHandlerFunc))
  53.     beego.Run()
  54. }

JS code:

  1. if (!window.location.origin) { // Some browsers (mainly IE) do not have this property, so we need to build it manually...
  2.     window.location.origin = window.location.protocol + '//' + window.location.hostname + (window.location.port ? (':' + window.location.port) : '');
  3. }
  4. var recInterval = null;
  5. var socket = null;
  8. var new_conn = function() {
  9.     socket = new SockJS('/live_update', null, {
  10.         'protocols_whitelist': ['websocket', 'xdr-streaming', 'xhr-streaming',
  11.             'iframe-eventsource', 'iframe-htmlfile',
  12.             'xdr-polling', 'xhr-polling', 'iframe-xhr-polling',
  13.             'jsonp-polling'
  14.         ]
  15.     });
  16.     clearInterval(recInterval);
  18.     socket.onclose = function() {
  19.         socket = null;
  20.         recInterval = setInterval(function() {
  21.             new_conn();
  22.         }, 2000);
  23.     };
  24.     socket.onmessage = function(e) {
  25.         document.getElementById("output").value += e.data +"\n";
  26.     };
  27. };
  29. (function () {
  30.     new_conn();
  31. })();

The above example implemented a simple echo app for sockjs, and you can use http.Handler for more extensions.