package proto.session.servlet;

import java.io.IOException;

import javax.servlet.ServletContext;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.servlet.http.HttpSession;

/**

 * Servlet implementation class CreateSessionBinding

 */

public class CreateSessionBinding extends HttpServlet {

    private static final long serialVersionUID = 1L;

    /**

     * @see HttpServlet#HttpServlet()

     */

    public CreateSessionBinding() {

        super();

        // TODO Auto-generated constructor stub

    }

    /**

     * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)

     */

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

        // TODO Auto-generated method stub

        createSessionListener(request, response);

    }

    /**

     * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)

     */

    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

        // TODO Auto-generated method stub

        createSessionListener(request, response);

    }

    private void createSessionListener (HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

        HttpSession session = request.getSession(true);

        ServletContext context = getServletContext();

        // Add a CustomBindingListener

        if (session.isNew()) {

            session.setAttribute("session.id", new SessionBindingListener(context));

            context.log("new session.binding : " + session.getId());

        } else {

            context.log("already created session");

        }

    }

}

package proto.session.servlet;

import javax.servlet.ServletContext;

import javax.servlet.http.HttpSessionBindingEvent;

import javax.servlet.http.HttpSessionBindingListener;

public class SessionBindingListener implements HttpSessionBindingListener {

    private ServletContext context;

    public SessionBindingListener(ServletContext context) {

        this.context = context;

    }

    public void valueBound(HttpSessionBindingEvent event) {

      context.log("BOUND to " + event.getSession().getId());

    }

    public void valueUnbound(HttpSessionBindingEvent event) {

        context.log("UNBOUND from " + event.getSession().getId());

    }

}

package proto.dwp.comet;

import java.io.IOException;

import java.io.InputStream;

import java.io.PrintWriter;

import java.util.ArrayList;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.apache.catalina.CometEvent;

import org.apache.catalina.CometProcessor;

/**

 * Servlet implementation class ChatServlet

 */

public class ChatServlet extends HttpServlet implements CometProcessor {

    private static final long serialVersionUID = 1L;

    protected ArrayList<HttpServletResponse> connections = new ArrayList<HttpServletResponse>();

    protected MessageSender messageSender = null;

    /**

     * @see HttpServlet#HttpServlet()

     */

    public ChatServlet() {

        super();

        // TODO Auto-generated constructor stub

    }

    /**

     * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)

     */

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

        // TODO Auto-generated method stub

    }

    /**

     * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)

     */

    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

        // TODO Auto-generated method stub

    }

    public void init() throws ServletException {

        messageSender = new MessageSender();

        Thread messageSenderThread = new Thread(messageSender, "MessageSender[" + getServletContext().getContextPath() + "]");

        messageSenderThread.setDaemon(true);

        messageSenderThread.start();

    }

    public void destroy() {

        connections.clear();

        messageSender.stop();

        messageSender = null;

    }

    /**

     * Process the given Comet event.

     *

     * @param event The Comet event that will be processed

     * @throws IOException

     * @throws ServletException

     */

    public void event(CometEvent event) throws IOException, ServletException {

        HttpServletRequest request = event.getHttpServletRequest();

        HttpServletResponse response = event.getHttpServletResponse();

         if (event.getEventType() == CometEvent.EventType.BEGIN) {

            log("Begin for session: " + request.getSession(true).getId());
            response.setContentType("text/html; charset=utf-8");
/* 

            PrintWriter writer = response.getWriter();

            writer.println("<!doctype html public \"-//w3c//dtd html 4.0 transitional//en\">");

            writer.println("<head><title>JSP Chat</title></head><body bgcolor=\"#FFFFFF\">");

            writer.flush();
*/ 

            synchronized (connections) {

                connections.add(response);

            }

        } else if (event.getEventType() == CometEvent.EventType.ERROR) {

            log("Error for session: " + request.getSession(true).getId());

            synchronized (connections) {

                connections.remove(response);

            }

            event.close();

        } else if (event.getEventType() == CometEvent.EventType.END) {

            log("End for session: " + request.getSession(true).getId());

            synchronized (connections) {

                connections.remove(response);

            }

            //PrintWriter writer = response.getWriter();

            //writer.println("</body></html>");

            event.close();

        } else if (event.getEventType() == CometEvent.EventType.READ) {

            InputStream is = request.getInputStream();

            byte[] buf = new byte[512];

            do {

                int n = is.read(buf); //can throw an IOException

                if (n > 0) {

                    log("Read " + n + " bytes: " + new String(buf, 0, n) + " for session: " + request.getSession(true).getId());

                    for ( int i=0; i<10; i++ ) {

                        try {

                            messageSender.send("SYSTEM", "Loop Count : " + i);

                            Thread.sleep(5000);

                        } catch (InterruptedException e) {

                        }

                    }

                } else if (n < 0) {

                    error(event, request, response);

                    return;

                }

            } while (is.available() > 0);

        }

    }

    public void error(CometEvent event, HttpServletRequest request, HttpServletResponse response) {

        log("error");

    }

    public class MessageSender implements Runnable {

        protected boolean running = true;

        protected ArrayList<String> messages = new ArrayList<String>();

        public MessageSender() {

        }

        public void stop() {

            running = false;

        }

        /**

         * Add message for sending.

         */

        public void send(String user, String message) {

            synchronized (messages) {

                messages.add("[" + user + "]: " + message);

                messages.notify();

            }

        }

        public void run() {

            while (running) {

                if (messages.size() == 0) {

                    try {

                        synchronized (messages) {

                            messages.wait();

                        }

                    } catch (InterruptedException e) {

                        // Ignore

                    }

                }

                synchronized (connections) {

                    String[] pendingMessages = null;

                    synchronized (messages) {

                        pendingMessages = messages.toArray(new String[0]);

                        messages.clear();

                    }

                    // Send any pending message on all the open connections

                    for (int i = 0; i < connections.size(); i++) {

                        try {

                            PrintWriter writer = connections.get(i).getWriter();

                            for (int j = 0; j < pendingMessages.length; j++) {

                                writer.println(pendingMessages[j] + "<br>");

                            }

                            writer.flush();

                        } catch (IOException e) {

                            log("IOExeption sending message", e);

                        }

                    }

                }

            }

        }

    }

}

<%@ page language="java" contentType="text/html; charset=UTF-8"

    pageEncoding="UTF-8"%>

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">

<html>

<head>

<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

<title>Insert title here</title>

<script type="text/javascript">

var XHR = {

    conn : null,

    request : {

        url : '',

        method : 'GET',

        data : '',

        async : true

    },

    header : {

        key : [],

        value : {}

    },

    data : {

        key : [],

        value : {}

    },

    response : {

        type : "XML"

    },

    createConnection : function() {

        if (typeof window.XMLHttpRequest) {

            this.conn = new XMLHttpRequest();

        } else if (typeof window.ActiveXObject) {

            this.conn = new ActiveXObject("Microsoft.XMLHTTP");

        }

        return this.conn;

    },

    createRequestData : function() {

        var size = this.data.key.length;

        for ( var i = 0; i < size; i++) {

            this.request.data += this.data.key[i] + '='

                    + this.data.value[this.data.key[i]] + '&';

        }

        this.request.data = this.request.data.substr(0,

                this.request.data.length - 1);

        return this.request.data;

    },

    createRequestHeader : function() {

        var size = this.header.key.length;

        for ( var i = 0; i < size; i++) {

            this.conn.setRequestHeader(this.header.key[i],

                    this.header.value[this.header.key[i]]);

        }

    },

    open : function() {

        var requestUrl;

        if (this.request.method == 'GET') {

            requestUrl = this.request.url + '?' + this.request.data;

        } else {

            requestUrl = this.request.url;

        }

        this.conn.open(this.request.method, requestUrl, this.request.async);

    },

    send : function() {

        if (this.request.method == 'GET') {

            this.conn.send();

        } else {

            this.conn.send(this.request.data);

        }

    }

}

function xhrRequest() {

    XHR.data.value = {message:document.getElementById('inputMessage').value};
    XHR.request.data = '';

    XHR.createRequestData();

    XHR.conn.onreadystatechange = function () {

            switch ( XHR.conn.readyState ) {

                    case 0 : // XHR.conn.UNSENT :

                            break;

                    case 1 : // XHR.conn.OPENED :

                            break;

                    case 2 : // XHR.conn.HEADERS_RECEIVED :

                            break;

                    case 3 : // XHR.conn.LOADING :

                            document.getElementById('divChat').innerHTML += "CASE 3 : " + XHR.conn.responseText + "<br>";

                            break;

                    case 4 : // XHR.conn.DONE :

                            doReadyStateChange();

                            break;

            }

            /*

            별도로 수행해야 하는 함수 작성 필요

            */

            function doReadyStateChange() {

                    if ( XHR.conn.status >= 200 && XHR.conn.status < 300 ) {

                        console.log("message send success");

                        document.getElementById('divChat').innerHTML += "CASE 4 : " + XHR.conn.responseText + "<br>";

                        document.getElementById('divChat').scrollTop = document.getElementById('divChat').scrollHeight;

                        xhrRequest();

                    } else if ( XHR.conn.status == 404 ) {

                            alert('서버를 찾을 수 없어, 메시지를 전송하지 못했습니다.');

                    } else {

                            alert('알수 없는 오류가 발생하여, 메시지를 전송하지 못했습니다..');

                    }

            }

    };

    XHR.open();

    XHR.createRequestHeader();

    XHR.send();

}

function init() {

    XHR.request.url = "http://localhost:8080/proto.dwp.comet/ChatServlet";

    XHR.request.method = "POST"; // "POST";

    XHR.header.key = ["Content-Type"];

    XHR.header.value = {

            "Content-Type":"application/x-www-url-form-encoded"

    };

    XHR.data.key = ["message"];

    XHR.createConnection();

}

</script>

</head>

<body onload="init();">

Hello World

<hr>

<div id="divChat" style="font-size:10px; height:300px; overflow:auto"></div>

<input type="text" name="inputMessage" id="inputMessage"> <button onclick="xhrRequest(); return false;">초기전송</button>

</body>

</html>

package proto.dwp.comet;

import java.io.IOException;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.apache.catalina.CometEvent;

import org.apache.catalina.CometProcessor;

/**

 * Servlet implementation class BroadcasterServlet

 */

public class BroadcasterServlet extends HttpServlet implements CometProcessor {

    private static final long serialVersionUID = 1L;

    private MessageSender messageSender;

    /**

     * @see HttpServlet#HttpServlet()

     */

    public BroadcasterServlet() {

        super();

        // TODO Auto-generated constructor stub

        this.messageSender = new MessageSender();

    }

    /**

     * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)

     */

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

        // TODO Auto-generated method stub

    }

    /**

     * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)

     */

    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

        // TODO Auto-generated method stub

    }

    @Override

    public void event(CometEvent event) throws ServletException, IOException {

      HttpServletRequest request = event.getHttpServletRequest();

      HttpServletResponse response = event.getHttpServletResponse();

      String sessionId = request.getRequestedSessionId();

      if (CometEvent.EventType.BEGIN == event.getEventType()) {

        // 요청을 최초로 처리할 때 호출됨.

        response.setContentType("text/html; charset=utf-8");

        messageSender.addSession(sessionId, event);

      } else if (CometEvent.EventType.ERROR == event.getEventType()) {

        // IO 에러가 발생했을 때.

        messageSender.removeSession(sessionId);

        event.close(); // 요청 처리 완료.

      } else if (CometEvent.EventType.END == event.getEventType()) {

        // 요청 처리가 완료되었을 때

        log("End event");

      } else if (CometEvent.EventType.READ == event.getEventType()) {

        log("Read event");

      }

    }

}

package proto.dwp.comet;

import java.io.IOException;

import java.io.PrintWriter;

import java.util.Map;

import java.util.concurrent.BlockingQueue;

import java.util.concurrent.ConcurrentHashMap;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.LinkedBlockingQueue;

import javax.servlet.http.HttpServletResponse;

import org.apache.catalina.CometEvent;

public class MessageSender implements Runnable {

    private volatile boolean running = true;

    private final BlockingQueue<String> messages = new LinkedBlockingQueue<String>();

    private final Map<String, CometEvent> sessions = new ConcurrentHashMap<String, CometEvent>();

    private final ExecutorService executor = Executors.newFixedThreadPool(5);

    public void send(String message) {

        try {

            messages.put(message);

        } catch (InterruptedException ignore) {

            // ignore

        }

    }

    public void addSession(String id, CometEvent event) {

        sessions.put(id, event);

    }

    public void removeSession(String id) {

        sessions.remove(id);

    }

    public void stop() {

        this.running = false;

        this.executor.shutdown();

    }

    @Override

    public void run() {

        while (running) {

            String message = null;

            try {

                message = messages.take();

            } catch (InterruptedException ignore) {

                // ignore

            }

            for (String id : sessions.keySet()) {

                executor.submit(new Task(id, message));

            }

        }

    }

    private class Task implements Runnable {

        private String sessionId;

        private String message;

        public Task(String id, String msg) {

            sessionId = id;

            message = msg;

        }

        public void run() {

            CometEvent event = sessions.get(sessionId);

            if (null == event) {

                return;

            }

            HttpServletResponse response = event.getHttpServletResponse();

            PrintWriter out = null;

            try {

                out = response.getWriter();

                out.println(message);

                out.flush();

                response.flushBuffer();

            } catch (IOException naive) {

                naive.printStackTrace();

            } finally {

                try {

                    out.close();

                } catch (Exception ignore) {

                }

                try {

                    event.close();

                } catch (Exception ignore) {

                }

                sessions.remove(sessionId);

            }

        }

    }

}

package proto.phonegap;

import org.apache.cordova.DroidGap;

import android.os.Bundle;

public class helloworldActivity extends DroidGap {

    /** Called when the activity is first created. */

    @Override

    public void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);

        super.loadUrl("file:///android_asset/www/index.html");

    }

}

<!DOCTYPE HTML>

<html>

  <head>

    <title>PhoneGap</title>

  <script type="text/javascript" charset="utf-8" src="cordova-1.5.0.js"></script>

  <script type="text/javascript" charset="utf-8">

     function onLoad(){

          document.addEventListener("deviceready", onDeviceReady, true);

     }

     function onDeviceReady(){

          navigator.notification.alert("PhoneGap is working");

     }

  </script>

  </head>

  <body onload="onLoad();">

       <h1>Welcome to PhoneGap</h1>

       <h2>Edit assets/www/index.html</h2>

  </body>

</html>

<?xml version="1.0" encoding="utf-8"?>

<manifest xmlns:android="http://schemas.android.com/apk/res/android"

    package="proto.phonegap.helloworld"

    android:versionCode="1"

    android:versionName="1.0" >

    <supports-screens

        android:largeScreens="true"

        android:normalScreens="true"

        android:smallScreens="true"

        android:resizeable="true"

        android:anyDensity="true"

        />

        <uses-permission android:name="android.permission.CAMERA" />

        <uses-permission android:name="android.permission.VIBRATE" />

        <uses-permission android:name="android.permission.ACCESS_COARSE_LOCATION" />

        <uses-permission android:name="android.permission.ACCESS_FINE_LOCATION" />

        <uses-permission android:name="android.permission.ACCESS_LOCATION_EXTRA_COMMANDS" />

        <uses-permission android:name="android.permission.READ_PHONE_STATE" />

        <uses-permission android:name="android.permission.INTERNET" />

        <uses-permission android:name="android.permission.RECEIVE_SMS" />

        <uses-permission android:name="android.permission.RECORD_AUDIO" />

        <uses-permission android:name="android.permission.MODIFY_AUDIO_SETTINGS" />

        <uses-permission android:name="android.permission.READ_CONTACTS" />

        <uses-permission android:name="android.permission.WRITE_CONTACTS" />

        <uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />

        <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />

    <uses-sdk android:minSdkVersion="8" />

    <application

        android:icon="@drawable/ic_launcher"

        android:label="@string/app_name" >

        <activity

            android:name="proto.phonegap.helloworldActivity"

            android:label="@string/app_name" android:configChanges="orientation|keyboardHidden">

            <intent-filter>

                <action android:name="android.intent.action.MAIN" />

                <category android:name="android.intent.category.LAUNCHER" />

            </intent-filter>

        </activity>

    </application>

</manifest>

package proto.board.web;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.ui.Model;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import proto.board.service.BoardContentViewService;

@Controller

public class BoardContentViewController {

    private static final Logger logger = LoggerFactory.getLogger(BoardContentViewController.class);

    @Autowired

    private BoardContentViewService boardContentViewService;

    public void setBoardContentViewService(BoardContentViewService boardContentViewService) {

        this.boardContentViewService = boardContentViewService;

    }

    @RequestMapping(value = "/boardContentView")

    public String boardContentView(Model model) {

        model.addAttribute("val", boardContentViewService.getBoardContentVO() );

        return "boardContentView";

    }

}

package proto.board.web;

import static org.junit.Assert.*;

import javax.inject.Inject;

import org.junit.After;

import org.junit.AfterClass;

import org.junit.Before;

import org.junit.BeforeClass;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.mockito.Mock;

import org.mockito.Mockito;

import org.mockito.runners.MockitoJUnitRunner;

import org.springframework.context.ApplicationContext;

import org.springframework.mock.web.MockHttpServletRequest;

import org.springframework.mock.web.MockHttpServletResponse;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.ui.ExtendedModelMap;

import org.springframework.ui.Model;

import org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter;

import proto.board.domain.BoardContentVO;

import proto.board.service.BoardContentViewService;

@RunWith(MockitoJUnitRunner.class)

@ContextConfiguration(locations={"file:src/main/webapp/WEB-INF/spring/appServlet/servlet-context.xml", "classpath:context/applicationContext-mybatis.xml"})

public class BoardContentViewControllerTest {

    @Inject

    private ApplicationContext applicationContext;

    private MockHttpServletRequest request;

    private MockHttpServletResponse response;

    private AnnotationMethodHandlerAdapter adapter;

    private BoardContentViewController controller;

    @Mock

    private BoardContentViewService boardContentViewService;

    @Mock

    private BoardContentVO boardContentVO;

    @BeforeClass

    public static void setUpBeforeClass() throws Exception {

    }

    @AfterClass

    public static void tearDownAfterClass() throws Exception {

    }

    @Before

    public void setUp() throws Exception {

        this.request = new MockHttpServletRequest();

        this.response = new MockHttpServletResponse();

        this.adapter = new AnnotationMethodHandlerAdapter();

        this.controller = new BoardContentViewController();

        this.controller.setBoardContentViewService(boardContentViewService);

    }

    @After

    public void tearDown() throws Exception {

    }

    @Test

    public void testBoardContentView () throws Exception {

        request.setMethod("GET");

        request.setRequestURI("/boardContentView");

        boardContentVO.setContent("content");

        boardContentVO.setDocumentSrl(1234);

        boardContentVO.setEmail("sophistlv@nhn.com");

        boardContentVO.setNickname("henry");

        boardContentVO.setRegdate("20120319121212");

        boardContentVO.setTitle("title");

        Mockito.when(boardContentViewService.getBoardContentVO()).thenReturn(boardContentVO);

        Model model = new ExtendedModelMap();

        String view = controller.boardContentView(model);

        assertEquals("boardContentView", view);

    }

}

<!-- spring framework test 설정 -->

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-test</artifactId>

            <version>${org.springframework-version}</version>

        </dependency>

 <!-- mockito -->

        <dependency>

            <groupId>org.mockito</groupId>

            <artifactId>mockito-all</artifactId>

            <version>1.9.0</version>

            <scope>test</scope>

        </dependency>

<!-- junit -->

        <dependency>

            <groupId>junit</groupId>

            <artifactId>junit</artifactId>

            <version>4.7</version>

            <scope>test</scope>

11.1 text/event-stream

This registration is for community review and will be submitted to the IESG for review, approval, and registration with IANA.

Type name:

text

Subtype name:

event-stream

Required parameters:

No parameters

Optional parameters:

charset

The charset parameter may be provided. The parameter's value must be "utf-8". This parameter serves no purpose; it is only allowed for compatibility with legacy servers.

Encoding considerations:

8bit (always UTF-8)

Security considerations:

An event stream from an origin distinct from the origin of the content consuming the event stream can result in information leakage. To avoid this, user agents are required to apply CORS semantics. [CORS]

Event streams can overwhelm a user agent; a user agent is expected to apply suitable restrictions to avoid depleting local resources because of an overabundance of information from an event stream.

Servers can be overwhelmed if a situation develops in which the server is causing clients to reconnect rapidly. Servers should use a 5xx status code to indicate capacity problems, as this will prevent conforming clients from reconnecting automatically.

Interoperability considerations:

Rules for processing both conforming and non-conforming content are defined in this specification.

Published specification:

This document is the relevant specification.

Applications that use this media type:

Web browsers and tools using Web services.

Additional information:

Magic number(s):

No sequence of bytes can uniquely identify an event stream.

File extension(s):

No specific file extensions are recommended for this type.

Macintosh file type code(s):

No specific Macintosh file type codes are recommended for this type.

<!DOCTYPE html>

<html>

<head>

<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

<title>HTML5 API::Server Sent Event::Chatting</title>

<script type="text/javascript">

//<![CDATA[

var messageVO = {

sender:'henry',

receiver:'jjeong',

message:''

}

var eventSource = new EventSource('http://localhost/status.html?f=henry.txt');

var XHR = {

conn : null,

request : {

url : '',

method : 'GET',

data : '',

async : true

},

header : {

key : [],

value : {}

},

data : {

key : [],

value : {}

},

response : {

type : "XML"

},

createConnection : function() {

if (typeof window.XMLHttpRequest) {

this.conn = new XMLHttpRequest();

} else if (typeof window.ActiveXObject) {

this.conn = new ActiveXObject("Microsoft.XMLHTTP");

}

return this.conn;

},

createRequestData : function() {

var size = this.data.key.length;

for ( var i = 0; i < size; i++) {

this.request.data += this.data.key[i] + '='

+ this.data.value[this.data.key[i]] + '&';

}

this.request.data = this.request.data.substr(0,

this.request.data.length - 1);

return this.request.data;

},

createRequestHeader : function() {

var size = this.header.key.length;

for ( var i = 0; i < size; i++) {

this.conn.setRequestHeader(this.header.key[i],

this.header.value[this.header.key[i]]);

}

},

open : function() {

var requestUrl;

if (this.request.method == 'GET') {

requestUrl = this.request.url + '?' + this.request.data;

} else {

requestUrl = this.request.url;

}

this.conn.open(this.request.method, requestUrl, this.request.async);

},

send : function() {

if (this.request.method == 'GET') {

this.conn.send();

} else {

this.conn.send(this.request.data);

}

}

}

eventSource.onopen = function (event) {

console.log("onopen");

};

eventSource.onmessage = function (event) {

document.getElementById('divChat').innerHTML += event.data + "<br>";

document.getElementById('divChat').scrollTop = document.getElementById('divChat').scrollHeight;

}

XHR.request.url = "http://localhost/messages.html";

XHR.request.method = "GET"; // "POST";

XHR.header.key = ["Content-Type"];

XHR.header.value = {

        "Content-Type":"application/x-www-form-urlencoded"

};

XHR.data.key = ["sender", "receiver", "message"];

function xhrRequest(m) {

        XHR.createConnection();

XHR.data.value = {sender:messageVO.sender, receiver:messageVO.receiver, message:m};

        XHR.createRequestData();

        XHR.conn.onreadystatechange = function () {

                switch ( XHR.conn.readyState ) {

                        case 0 : // XHR.conn.UNSENT :

                                break;

                        case 1 : // XHR.conn.OPENED :

                                break;

                        case 2 : // XHR.conn.HEADERS_RECEIVED :

                                break;

                        case 3 : // XHR.conn.LOADING :

                                break;

                        case 4 : // XHR.conn.DONE :

                                doReadyStateChange();

                                break;

                }

                /*

                별도로 수행해야 하는 함수 작성 필요

                */

                function doReadyStateChange() {

                        if ( XHR.conn.status >= 200 && XHR.conn.status < 300 ) {

console.log("message send success");

document.getElementById('divChat').innerHTML += m + "<br>";

document.getElementById('divChat').scrollTop = document.getElementById('divChat').scrollHeight;

                        } else if ( XHR.conn.status == 404 ) {

                                alert('서버를 찾을 수 없어, 메시지를 전송하지 못했습니다.');

                        } else {

                                alert('알수 없는 오류가 발생하여, 메시지를 전송하지 못했습니다..');

                        }

                }

        };

        XHR.open();

        XHR.createRequestHeader();

        XHR.send();

}

//]]>

</script>

</head>

<body>

<div id="divChat" style="height:400px; overflow:auto"></div>

<input type="text" name="inputMessage" id="inputMessage"> <button onclick="xhrRequest(document.getElementById('inputMessage').value); return false;">전송</button>

</body>

</html>