Как я могу обновлять метод write.out сервлета каждые 10 секунд? - PullRequest
0 голосов
/ 15 марта 2012

У меня есть сервлет, который подключается к базе данных mysql, результирующий набор получает некоторые значения из столбца с числовыми значениями, эти значения идут по ссылке Google, которая в результате создает диаграмму в виде изображения ... это мой код за это:

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

            //OutputStreamWriter writer = new OutputStreamWriter(response.getOutputStream());
            //System.out.println("SensorGraph");

            response.setContentType("text/html");
            PrintWriter out = response.getWriter();
            //sensor Id
            String id = request.getParameter("id");
            // limit in the query
            String limit = request.getParameter("limit");
            DatabaseConnection db_connection =  new DatabaseConnection()._instance;
            Connection connection = null;
            try {
                connection = db_connection.getConnection();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            Statement statement;
            ResultSet resultSet;
            try {
                statement = (Statement) connection.createStatement();
                resultSet = statement.executeQuery("select * from Sensor_Entries order by EntryTime asc limit 100");
                String values = "";
                while(resultSet.next()) {
                    String value = resultSet.getString("EntryValue");
                    values += (value) + ",";
                }
                //System.out.println(values);
                values = values.substring(0, values.length()-1);


                String image = "http://chart.apis.google.com/chart?" +
                        "chxr=0,0,1000" +
                        "&chxs=0,676767,12.167,-0.5,l,676767" +
                        "&chxt=y" +
                        "&chs=1000x300" +
                        "&cht=ls" +
                        "&chco=3D7930" +
                        "&chds=0,1000" +
                        "&chd=t:" + values+
                        "&chg=14.3,-1,1,1" +
                        "&chls=2,4,0" +
                        "&chma=0,6%7C3" +
                        "&chm=B,C5D4B5BB,0,0,0" +
                        "&chtt=Sensor+Values" +
                        "&chts=F00D0D,14.5";

                //if(request.getParameter("img") != null)
                    out.write("<img src=\"" + image + "\" />");

                statement = (Statement) connection.createStatement();
                /*resultSet = statement.executeQuery("select * from Sensors join " +
                        "(select * from Sensor_Entries order by EntryTime desc) as Sensor_Entries on " +
                        "(Sensors.SensorID=Sensor_Entries.SensorID) where Sensors.SensorID='" + id + "' " +
                        "group by Sensors.SensorID;");*/

                resultSet = statement.executeQuery("select * from Sensors join " +
                        "(select * from Sensor_Entries order by EntryTime desc) as Sensor_Entries on " +
                        "(Sensors.SensorID=Sensor_Entries.SensorID)"); /*where Sensors.SensorID='" + id + "' " +
                        "group by Sensors.SensorID;");*/

                ResultSetMetaData resultSetMetaData = (ResultSetMetaData) resultSet.getMetaData();
                if(resultSet.next()) {
                    out.write("<table>");
                    for(int i = 1; i < resultSetMetaData.getColumnCount() + 1; i++) {
                        String value = "";
                        int type = resultSetMetaData.getColumnType(i);
                        if(type == Types.INTEGER || type == Types.TINYINT) {
                            value = "" + resultSet.getInt(i);
                        } else if(type == Types.VARCHAR) {
                            value = resultSet.getString(i);
                        } else if(type == Types.TIMESTAMP) {
                            value = resultSet.getTimestamp(i).toString();
                        } else if(type == Types.DOUBLE) {
                            value = "" + resultSet.getDouble(i);
                        }

                        //out.write("<tr>" +
                               // "<td>" + resultSetMetaData.getColumnName(i) + "</td>" +
                               // "<td>" + value + "</td>" +
                                //"</tr>");
                    }
                    out.write("</table></center>");
                }
                else
                    out.write(image);
                out.flush();
                out.close();
            } catch (SQLException ignored) { ignored.printStackTrace();  }
        }

/**
 * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
 */
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    doGet(request, response);

}

КАК МОЖНО ПОЛУЧИТЬ НОВЫЙ ГРАФ КАЖДЫХ 10 СЕКУНД, ПРЕДОСТАВЛЯЯ, ЧТО Я ЗНАЮ, ЧТО ЗНАЧЕНИЯ ИЗМЕНЯЮТСЯ В КОЛОННЕ С ЗНАЧЕНИЯМИ? ... ПОЖАЛУЙСТА, ПОМОГИТЕ МНЕ ...

1 Ответ

1 голос
/ 16 марта 2012

Нельзя сбрасывать ServletOutputStream несколько раз. Это будет жаловаться. Вам нужно будет создать поток фоновой обработки с каким-то идентификатором и использовать ajax со стороны клиента для получения текущего набора вычислений и их рендеринга.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...