websocket chat example

chat.js

 var chatUrl = 'http://'+document.location.hostname+':'+document.location.port+'/GrailsChat/atmosphere/chatty';

ChatService.groovy

class ChatService {

    static transactional = false
    static atmosphere = [mapping: '/atmosphere/chatty']

ChatService2.groovy

    def onRequest = { event ->
       
        try {
            AtmosphereRequest req = event.request
            if (req.method.equalsIgnoreCase("GET")) {
                event.suspend()
            } else if (req.method.equalsIgnoreCase("POST")) {
                String stuff = req.reader.readLine().trim()
                event.broadcaster.broadcast(stuff)
            }
        } catch (Exception e) {
            println "ERROR!!!!!"
        }
    }

ChatService3.groovy

    def onStateChange = { event ->
        AtmosphereResource r = event.resource
        AtmosphereResponse res = r.response

        try {
            if (event.isSuspended()) {
                String body = event.message.toString()
                String author = body.substring(body.indexOf(":") + 2, body.indexOf(",") - 1);
                String message = body.substring(body.lastIndexOf(":") + 2, body.length() - 2);
                res.writer.write( createMessage(author, message) )

                switch (r.transport()) {
                    case TRANSPORT.JSONP:
                    case TRANSPORT.LONG_POLLING:
                        event.resource.resume()
                        break
                    default:
                        res.writer.flush()
                }
            } else if (!event.isResuming()) {
                event.broadcaster().broadcast( createMessage('someone', 'buh gye') )
            }
        } catch (Exception e) {
            println "ERROR in onStateChange: $e"
        }
    }

    private String createMessage(String author, String text) {
        return "{ \"text\" : \"" + text + "\", \"author\" : \"" + author + "\" , \"time\" : " + new Date().time + "}"
    }