admin 的blog

祝你愉快

由 admin 于 周一, 2008-06-30 13:26 提交。

8f24191f5a6c11e6e1fe0b47 c18a571f2951d404304e15a9 

天空海阔是无尽美梦
可惜只得一个破天空
寻求人间仅有的希望
骤觉得到了又已失去了
不懂欢笑像留下缺陷
哥哥可否知道我的心
常常埋怨仿似不长大
是你给予我留我一点真
默默悼念默默愤怒埋怨
一生充满了斗志永不倦
怎可终止
他的生命是真理
他的生命没扭转
但愿在你的远方
可听得到我这歌
常欠缺了你在旁
陪伴上路多么不安
但愿用这一阙歌
来冲洗心中我苦楚
来叫喊我对你未忘
含泪说声
祝你愉快
看天空可变改

»

技术交流

由 admin 于 周四, 2008-06-26 16:33 提交。
»

My House RC4

由 admin 于 周五, 2008-06-20 13:25 提交。

昨天把装修公司定了，选的的是大兴本地的一家装修公司，主要是他们活比较细致，价格比较合理。这是他们给的效果图。

卧室柜 客厅

电脑桌 背景墙副本

 过道 门厅

阳台 书柜

卧室

»

Tomcat 6支持的Comet

由 admin 于 周三, 2007-11-14 23:21 提交。

今天在测试中无意中看到Tomcat 6的新特性Comet，使用Comet技术可以轻松实现一个Pushlet的功能，让我看了着实兴奋不已，而其官方网站还给出了一个Messenger的例子。

  1. public class ChatServlet
  2.     extends HttpServlet implements CometProcessor {
  3.  
  4.     protected ArrayList<HttpServletResponse> connections = 
  5.         new ArrayList<HttpServletResponse>();
  6.     protected MessageSender messageSender = null;
  7.     
  8.     public void init() throws ServletException {
  9.         messageSender = new MessageSender();
  10.         Thread messageSenderThread = 
  11.             new Thread(messageSender, "MessageSender[" + getServletContext().getContextPath() + "]");
  12.         messageSenderThread.setDaemon(true);
  13.         messageSenderThread.start();
  14.     }
  15.  
  16.     public void destroy() {
  17.         connections.clear();
  18.         messageSender.stop();
  19.         messageSender = null;
  20.     }
  21.  
  22.     /**
  23.      * Process the given Comet event.
  24.      * 
  25.      * @param event The Comet event that will be processed
  26.      * @throws IOException
  27.      * @throws ServletException
  28.      */
  29.     public void event(CometEvent event)
  30.         throws IOException, ServletException {
  31.         HttpServletRequest request = event.getHttpServletRequest();
  32.         HttpServletResponse response = event.getHttpServletResponse();
  33.         if (event.getEventType() == CometEvent.EventType.BEGIN) {
  34.             log("Begin for session: " + request.getSession(true).getId());
  35.             PrintWriter writer = response.getWriter();
  36.             writer.println("<!doctype html public \"-//w3c//dtd html 4.0 transitional//en\">");
  37.             writer.println("<head><title>JSP Chat</title></head><body bgcolor=\"#FFFFFF\">");
  38.             writer.flush();
  39.             synchronized(connections) {
  40.                 connections.add(response);
  41.             }
  42.         } else if (event.getEventType() == CometEvent.EventType.ERROR) {
  43.             log("Error for session: " + request.getSession(true).getId());
  44.             synchronized(connections) {
  45.                 connections.remove(response);
  46.             }
  47.             event.close();
  48.         } else if (event.getEventType() == CometEvent.EventType.END) {
  49.             log("End for session: " + request.getSession(true).getId());
  50.             synchronized(connections) {
  51.                 connections.remove(response);
  52.             }
  53.             PrintWriter writer = response.getWriter();
  54.             writer.println("</body></html>");
  55.             event.close();
  56.         } else if (event.getEventType() == CometEvent.EventType.READ) {
  57.             InputStream is = request.getInputStream();
  58.             byte[] buf = new byte[512];
  59.             do {
  60.                 int n = is.read(buf); //can throw an IOException
  61.                 if (n > 0) {
  62.                     log("Read " + n + " bytes: " + new String(buf, 0, n) 
  63.                             + " for session: " + request.getSession(true).getId());
  64.                 } else if (n < 0) {
  65.                     error(event, request, response);
  66.                     return;
  67.                 }
  68.             } while (is.available() > 0);
  69.         }
  70.     }
  71.  
  72.     public class MessageSender implements Runnable {
  73.  
  74.         protected boolean running = true;
  75.         protected ArrayList<String> messages = new ArrayList<String>();
  76.         
  77.         public MessageSender() {
  78.         }
  79.         
  80.         public void stop() {
  81.             running = false;
  82.         }
  83.  
  84.         /**
  85.          * Add message for sending.
  86.          */
  87.         public void send(String user, String message) {
  88.             synchronized (messages) {
  89.                 messages.add("[" + user + "]: " + message);
  90.                 messages.notify();
  91.             }
  92.         }
  93.  
  94.         public void run() {
  95.  
  96.             while (running) {
  97.  
  98.                 if (messages.size() == 0) {
  99.                     try {
  100.                         synchronized (messages) {
  101.                             messages.wait();
  102.                         }
  103.                     } catch (InterruptedException e) {
  104.                         // Ignore
  105.                     }
  106.                 }
  107.  
  108.                 synchronized (connections) {
  109.                     String[] pendingMessages = null;
  110.                     synchronized (messages) {
  111.                         pendingMessages = messages.toArray(new String[0]);
  112.                         messages.clear();
  113.                     }
  114.                     // Send any pending message on all the open connections
  115.                     for (int i = 0; i < connections.size(); i++) {
  116.                         try {
  117.                             PrintWriter writer = connections.get(i).getWriter();
  118.                             for (int j = 0; j < pendingMessages.length; j++) {
  119.                                 writer.println(pendingMessages[j] + "<br>");
  120.                             }
  121.                             writer.flush();
  122.                         } catch (IOException e) {
  123.                             log("IOExeption sending message", e);
  124.                         }
  125.                     }
  126.                 }
  127.  
  128.             }
  129.  
  130.         }
  131.  
  132.     }
  133.  
  134. }

Archived in
»

64位RedHat AS5安装PHP JSON模块

由 admin 于 周三, 2007-11-14 23:02 提交。

最近安装了一台RedHat AS5 64bit的服务器，但是在安装完后返现默认安装的PHP中居然没有装载JSON模块。在PHP的官方网站上看到可以使用PECL安装PHP的模块。

#pecl install json

安装编译很顺利但是到后面的模块测试时出错，错误如下：

Fatal error: Allowed memory size of 8388608 bytes exhausted (tried to allocate 143 bytes) in /usr/share/pear/PEAR/PackageFile/v2.php on line 1058

在此执行pecl install json系统提示已经安装过json模块，使用php -m系统给出如下错误：

PHP Warning: PHP Startup: Unable to load dynamic library '/usr/lib64/php/modules/json' - /usr/lib64/php/modules/json: cannot open shared object file: No such file or directory in Unknown on line 0

于是查看/etc/php.ini文件，返现extension=json，将其改为extension=json.so，运行

#php -m
发现json安装正常，不知道是不是PHPJSON大意将extension=json.so写成了extension=json

Archived in
»