随笔-20  评论-2  文章-0  trackbacks-0
  2009年5月10日
**
 * <pre>
 * Title:         HttpRequestProxy.java
 * Project:     HP-Common
 * Type:        com.hengpeng.common.web.HttpRequestProxy
 * Author:        benl
 * Create:         2007-7-3 上午03:07:07
 * Copyright:     Copyright (c) 2007
 * Company:
 * <pre>
 */
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;

import org.apache.log4j.Logger;

/**
 * <pre>
 * HTTP请求代理类
 * </pre>
 *
 * @author benl
 * @version 1.0, 2007-7-3
 */
public class HttpRequestProxy
{
    /**
     * 连接超时
     */
    private static int connectTimeOut = 5000;

    /**
     * 读取数据超时
     */
    private static int readTimeOut = 10000;

    /**
     * 请求编码
     */
    private static String requestEncoding = "GBK";

    private static Logger logger = Logger.getLogger(HttpRequestProxy.class);

    /**
     * <pre>
     * 发送带参数的GET的HTTP请求
     * </pre>
     *
     * @param reqUrl HTTP请求URL
     * @param parameters 参数映射表
     * @return HTTP响应的字符串
     */
    public static String doGet(String reqUrl, Map parameters,
            String recvEncoding)
    {
        HttpURLConnection url_con = null;
        String responseContent = null;
        try
        {
            StringBuffer params = new StringBuffer();
            for (Iterator iter = parameters.entrySet().iterator(); iter
                    .hasNext();)
            {
                Entry element = (Entry) iter.next();
                params.append(element.getKey().toString());
                params.append("=");
                params.append(URLEncoder.encode(element.getValue().toString(),
                        HttpRequestProxy.requestEncoding));
                params.append("&");
            }

            if (params.length() > 0)
            {
                params = params.deleteCharAt(params.length() - 1);
            }

            URL url = new URL(reqUrl);
            url_con = (HttpURLConnection) url.openConnection();
            url_con.setRequestMethod("GET");
            System.setProperty("sun.net.client.defaultConnectTimeout", String
                    .valueOf(HttpRequestProxy.connectTimeOut));// (单位:毫秒)jdk1.4换成这个,连接超时
            System.setProperty("sun.net.client.defaultReadTimeout", String
                    .valueOf(HttpRequestProxy.readTimeOut)); // (单位:毫秒)jdk1.4换成这个,读操作超时
            // url_con.setConnectTimeout(5000);//(单位:毫秒)jdk
            // 1.5换成这个,连接超时
            // url_con.setReadTimeout(5000);//(单位:毫秒)jdk 1.5换成这个,读操作超时
            url_con.setDoOutput(true);
            byte[] b = params.toString().getBytes();
            url_con.getOutputStream().write(b, 0, b.length);
            url_con.getOutputStream().flush();
            url_con.getOutputStream().close();

            InputStream in = url_con.getInputStream();
            BufferedReader rd = new BufferedReader(new InputStreamReader(in,
                    recvEncoding));
            String tempLine = rd.readLine();
            StringBuffer temp = new StringBuffer();
            String crlf=System.getProperty("line.separator");
            while (tempLine != null)
            {
                temp.append(tempLine);
                temp.append(crlf);
                tempLine = rd.readLine();
            }
            responseContent = temp.toString();
            rd.close();
            in.close();
        }
        catch (IOException e)
        {
            logger.error("网络故障", e);
        }
        finally
        {
            if (url_con != null)
            {
                url_con.disconnect();
            }
        }

        return responseContent;
    }

    /**
     * <pre>
     * 发送不带参数的GET的HTTP请求
     * </pre>
     *
     * @param reqUrl HTTP请求URL
     * @return HTTP响应的字符串
     */
    public static String doGet(String reqUrl, String recvEncoding)
    {
        HttpURLConnection url_con = null;
        String responseContent = null;
        try
        {
            StringBuffer params = new StringBuffer();
            String queryUrl = reqUrl;
            int paramIndex = reqUrl.indexOf("?");

            if (paramIndex > 0)
            {
                queryUrl = reqUrl.substring(0, paramIndex);
                String parameters = reqUrl.substring(paramIndex + 1, reqUrl
                        .length());
                String[] paramArray = parameters.split("&");
                for (int i = 0; i < paramArray.length; i++)
                {
                    String string = paramArray[i];
                    int index = string.indexOf("=");
                    if (index > 0)
                    {
                        String parameter = string.substring(0, index);
                        String value = string.substring(index + 1, string
                                .length());
                        params.append(parameter);
                        params.append("=");
                        params.append(URLEncoder.encode(value,
                                HttpRequestProxy.requestEncoding));
                        params.append("&");
                    }
                }

                params = params.deleteCharAt(params.length() - 1);
            }

            URL url = new URL(queryUrl);
            url_con = (HttpURLConnection) url.openConnection();
            url_con.setRequestMethod("GET");
            System.setProperty("sun.net.client.defaultConnectTimeout", String
                    .valueOf(HttpRequestProxy.connectTimeOut));// (单位:毫秒)jdk1.4换成这个,连接超时
            System.setProperty("sun.net.client.defaultReadTimeout", String
                    .valueOf(HttpRequestProxy.readTimeOut)); // (单位:毫秒)jdk1.4换成这个,读操作超时
            // url_con.setConnectTimeout(5000);//(单位:毫秒)jdk
            // 1.5换成这个,连接超时
            // url_con.setReadTimeout(5000);//(单位:毫秒)jdk 1.5换成这个,读操作超时
            url_con.setDoOutput(true);
            byte[] b = params.toString().getBytes();
            url_con.getOutputStream().write(b, 0, b.length);
            url_con.getOutputStream().flush();
            url_con.getOutputStream().close();
            InputStream in = url_con.getInputStream();
            BufferedReader rd = new BufferedReader(new InputStreamReader(in,
                    recvEncoding));
            String tempLine = rd.readLine();
            StringBuffer temp = new StringBuffer();
            String crlf=System.getProperty("line.separator");
            while (tempLine != null)
            {
                temp.append(tempLine);
                temp.append(crlf);
                tempLine = rd.readLine();
            }
            responseContent = temp.toString();
            rd.close();
            in.close();
        }
        catch (IOException e)
        {
            logger.error("网络故障", e);
        }
        finally
        {
            if (url_con != null)
            {
                url_con.disconnect();
            }
        }

        return responseContent;
    }

    /**
     * <pre>
     * 发送带参数的POST的HTTP请求
     * </pre>
     *
     * @param reqUrl HTTP请求URL
     * @param parameters 参数映射表
     * @return HTTP响应的字符串
     */
    public static String doPost(String reqUrl, Map parameters,
            String recvEncoding)
    {
        HttpURLConnection url_con = null;
        String responseContent = null;
        try
        {
            StringBuffer params = new StringBuffer();
            for (Iterator iter = parameters.entrySet().iterator(); iter
                    .hasNext();)
            {
                Entry element = (Entry) iter.next();
                params.append(element.getKey().toString());
                params.append("=");
                params.append(URLEncoder.encode(element.getValue().toString(),
                        HttpRequestProxy.requestEncoding));
                params.append("&");
            }

            if (params.length() > 0)
            {
                params = params.deleteCharAt(params.length() - 1);
            }

            URL url = new URL(reqUrl);
            url_con = (HttpURLConnection) url.openConnection();
            url_con.setRequestMethod("POST");
            System.setProperty("sun.net.client.defaultConnectTimeout", String
                    .valueOf(HttpRequestProxy.connectTimeOut));// (单位:毫秒)jdk1.4换成这个,连接超时
            System.setProperty("sun.net.client.defaultReadTimeout", String
                    .valueOf(HttpRequestProxy.readTimeOut)); // (单位:毫秒)jdk1.4换成这个,读操作超时
            // url_con.setConnectTimeout(5000);//(单位:毫秒)jdk
            // 1.5换成这个,连接超时
            // url_con.setReadTimeout(5000);//(单位:毫秒)jdk 1.5换成这个,读操作超时
            url_con.setDoOutput(true);
            byte[] b = params.toString().getBytes();
            url_con.getOutputStream().write(b, 0, b.length);
            url_con.getOutputStream().flush();
            url_con.getOutputStream().close();

            InputStream in = url_con.getInputStream();
            BufferedReader rd = new BufferedReader(new InputStreamReader(in,
                    recvEncoding));
            String tempLine = rd.readLine();
            StringBuffer tempStr = new StringBuffer();
            String crlf=System.getProperty("line.separator");
            while (tempLine != null)
            {
                tempStr.append(tempLine);
                tempStr.append(crlf);
                tempLine = rd.readLine();
            }
            responseContent = tempStr.toString();
            rd.close();
            in.close();
        }
        catch (IOException e)
        {
            logger.error("网络故障", e);
        }
        finally
        {
            if (url_con != null)
            {
                url_con.disconnect();
            }
        }
        return responseContent;
    }

    /**
     * @return 连接超时(毫秒)
     * @see com.hengpeng.common.web.HttpRequestProxy#connectTimeOut
     */
    public static int getConnectTimeOut()
    {
        return HttpRequestProxy.connectTimeOut;
    }

    /**
     * @return 读取数据超时(毫秒)
     * @see com.hengpeng.common.web.HttpRequestProxy#readTimeOut
     */
    public static int getReadTimeOut()
    {
        return HttpRequestProxy.readTimeOut;
    }

    /**
     * @return 请求编码
     * @see com.hengpeng.common.web.HttpRequestProxy#requestEncoding
     */
    public static String getRequestEncoding()
    {
        return requestEncoding;
    }

    /**
     * @param connectTimeOut 连接超时(毫秒)
     * @see com.hengpeng.common.web.HttpRequestProxy#connectTimeOut
     */
    public static void setConnectTimeOut(int connectTimeOut)
    {
        HttpRequestProxy.connectTimeOut = connectTimeOut;
    }

    /**
     * @param readTimeOut 读取数据超时(毫秒)
     * @see com.hengpeng.common.web.HttpRequestProxy#readTimeOut
     */
    public static void setReadTimeOut(int readTimeOut)
    {
        HttpRequestProxy.readTimeOut = readTimeOut;
    }

    /**
     * @param requestEncoding 请求编码
     * @see com.hengpeng.common.web.HttpRequestProxy#requestEncoding
     */
    public static void setRequestEncoding(String requestEncoding)
    {
        HttpRequestProxy.requestEncoding = requestEncoding;
    }
   
    public static void main(String[] args)
    {
        Map map = new HashMap();
        map.put("actionType", "1");
//        map.put("issueId", "33");
        String temp = HttpRequestProxy.doPost("http://192.168.0.99/AgentPortal/autoHandler", map, "GBK");
        System.out.println("返回的消息是:"+temp);
       
    }
}

文章来源:http://blog.163.com/ccbobo_cat/blog/static/320994622009616102329953
posted @ 2009-07-16 10:23 C.B.K 阅读(1803) | 评论 (1)编辑 收藏

/*

下面的程序说明了怎样实现对象序列化和反序列化。它由实例化一个MyClass类的对象开始。该对象有三个实例变量,它们的类型分别是String,int和double。这是我们希望存储和恢复的信息。

FileOutputStream被创建,引用了一个名为“serial”的文件。为该文件流创建一个ObjectOutputStream。ObjectOutputStream 的writeObject( )方法用来序列化对象。对象的输出流被刷新和关闭。
然后,引用名为“serial”的文件创建一个FileInputStream类并为该文件创建一个ObjectInputStream类。ObjectInputStream 的readObject( )方法用来反序列化对象。然后对象输入流被关闭。
注意MyClass被定义成实现Serializable接口。如果不这样做,将会引发一个NotSerializableException异常。试图做一些把MyClass实例变量声明成transient的实验。那些数据在序列化过程中不被保存

*/

import java.io.*;
class MyClass implements Serializable{
 String s;
 int i;
 double d;
 public MyClass (String s,int i,double d){
  this.s = s;
  this.i = i;
  this.d = d;
 }
 public String toString(){
  return "s=" + s + "; i=" + i + "; d=" + d;
 }
}
class SerializationDemo{
 public static void main(String[] args){
  //Object serialization.
  try{
   MyClass object1 = new MyClass("Evan",9,9.9e10);
   System.out.println("object1 : " +object1);
   FileOutputStream fos = new FileOutputStream("serial");
   ObjectOutputStream oos = new ObjectOutputStream(fos);
   oos.writeObject(object1);
   oos.flush();
   oos.close();
  }catch(Exception e){
   System.out.println("Exception during serialization :" + e);
   System.exit(0);
  }
  //Object deserialization.
  try{
   MyClass object2 ;
   FileInputStream fis = new FileInputStream("serial");
   ObjectInputStream ois = new ObjectInputStream(fis);
   object2 = (MyClass)ois.readObject();
   ois.close();
   System.out.println("object2 : " +object2);
  }catch(Exception e){
   System.out.println("Exception during serialization :" + e);
   System.exit(0);
  }
 }
}


文章来源:http://blog.163.com/ccbobo_cat/blog/static/320994622009616101541196
posted @ 2009-07-16 10:16 C.B.K 阅读(168) | 评论 (0)编辑 收藏
Java的serialization提供了一种持久化对象实例的机制。当持久化对象时,可能有一个特殊的对象数据成员,我们不想
用serialization机制来保存它。为了在一个特定对象的一个域上关闭serialization,可以在这个域前加上关键字transient。
transient是Java语言的关键字,用来表示一个域不是该对象串行化的一部分。当一个对象被串行化的时候,transient型变量的值不包括在串行化的表示中,然而非transient型的变量是被包括进去的。

文章来源:http://blog.163.com/ccbobo_cat/blog/static/3209946220096161094144
posted @ 2009-07-16 10:09 C.B.K 阅读(152) | 评论 (0)编辑 收藏

匹配中文字符的正则表达式: [\u4e00-\u9fa5]
匹配双字节字符(包括汉字在内): [^\x00-\xff]

应用:计算字符串的长度(一个双字节字符长度计2,ASCII字符计1)
String.prototype.len=function(){return this.replace([^\x00-\xff]/g,"aa").length;}
匹配空行的正则表达式: \n[\s| ]*\r
匹配HTML标记的正则表达式: /<(.*)>.*<\/>|<(.*) \/>/
匹配首尾空格的正则表达式: (^\s*)|(\s*$)

应用:javascript中没有像vbscript那样的trim函数,我们就可以利用这个表达式来实现,如下:
String.prototype.trim = function() {
return this.replace(/(^\s*)|(\s*$)/g, "");
}


利用正则表达式分解和转换IP地址:
下面是利用正则表达式匹配IP地址,并将IP地址转换成对应数值的javascript程序:

function IP2V(ip) {
re=/(\d+)\.(\d+)\.(\d+)\.(\d+)/g //匹配IP地址的正则表达式
if(re.test(ip)) {
return RegExp.*Math.pow(255,3))+RegExp.*Math.pow(255,2))+RegExp.*255+RegExp.*1
}
else {
throw new Error("Not a valid IP address!")
}
}


不过上面的程序如果不用正则表达式,而直接用split函数来分解可能更简单,程序如下:

var ip="10.100.20.168"
ip=ip.split(".")
alert("IP值是:"+(ip[0]*255*255*255+ip[1]*255*255+ip[2]*255+ip[3]*1))
匹配Email地址的正则表达式: \w+([-+.]\w+)*@\w+([-.]\w+)*\.\w+([-.]\w+)*
匹配网址URL的正则表达式: http://([\w-]+\.)+[\w-]+(/[\w- ./?%&=]*)?


利用正则表达式去除字串中重复的字符的算法程序:

var s="abacabefgeeii"
var s1=s.replace(/(.).*/g,"")
var re=new RegExp("["+s1+"]","g")
var s2=s.replace(re,"")
alert(s1+s2) //结果为:abcefgi


用正则表达式从URL地址中提取文件名的javascript程序,如下结果为page1

s="http://www.9499.net/page1.htm"
s=s.replace(/(.*\/)([^\.]+).*/ig,"")
alert(s)


利用正则表达式限制网页表单里的文本框输入内容:

用正则表达式限制只能输入中文:
onkeyup="value=value.replace(/[^\u4E00-\u9FA5]/g,'')" onbeforepaste="clipboardData.setData('text',clipboardData.getData('text').replace(/[^\u4E00-\u9FA5]/g,''))"

用正则表达式限制只能输入全角字符:
onkeyup="value=value.replace(/[^\uFF00-\uFFFF]/g,'')" onbeforepaste="clipboardData.setData('text',clipboardData.getData('text').replace(/[^\uFF00-\uFFFF]/g,''))"

用正则表达式限制只能输入数字:
onkeyup="value=value.replace(/[^\d]/g,'') "onbeforepaste="clipboardData.setData('text',clipboardData.getData('text').replace(/[^\d]/g,''))"

用正则表达式限制只能输入数字和英文:
onkeyup="value=value.replace(/[\W]/g,'') "onbeforepaste="clipboardData.setData('text',clipboardData.getData('text').replace(/[^\d]/g,''))"


文章来源:http://blog.163.com/ccbobo_cat/blog/static/32099462200961005220547
posted @ 2009-07-10 12:52 C.B.K 阅读(206) | 评论 (0)编辑 收藏
ant手册中的ant配置classpath采用classpath标签,可是我发现这样配置总是不好用,还是直接用path可以使用
  设置classpath的方法有多种
<path id="project.classpath">
    1<pathelement path="${basedir}/lib/aa.jar"/>
   2<pathelement location="aa.jar"/>与1的区别在于location可以去当前路径,当然可以使用绝对路径
    3<filelist id="file" dir="${basedir}/lin">
          <file name="a.jar"/>
          <file name="d:lib/b.jar"/>
     </filelist>
   4<fileset dir="d:/lib">
       <include name="**/*.jar"/>
    </fileset>
   5手册上说了dirset也好用,但是我测试了还是不要用的
</path>   
  下面说classpath的使用
   样例如下
     <javac scdir="./src" destdir="./classes">
           <classpath refid="project.classpath"/> 
   </javac>


下面是比较四种方式的优缺点
   第一种调用的需要设置绝对路径适合第三方jar包
    第二种则适合jar包和build.xml文件在同一目录下的情况,但是我觉得两个文件放在一起本身就不合理,估计是用的情况不多。
  前两个都是设置单个jar包
   第三种是一个文件集合适合引入不同路径的jar包,但是需要输入每个jar包的名字,比较繁琐,适合于jar包属于不同位置,比较分散但是不多的情况
  第四种是一个文件夹,可以采用匹配模式来引入,这个适合在同一个文件夹下,文件名字比较多的情况下

文章来源:http://blog.163.com/ccbobo_cat/blog/static/32099462200961051533899
posted @ 2009-07-10 05:16 C.B.K 阅读(1641) | 评论 (0)编辑 收藏
ant的构建文件中,有很多核心类型,这些核心类型都是XXXSet的形式,主要有以下几个:PatternSet、DirSet、FileSet、PropertySet、ZipFileSet等。说下前三个的功能就应该可以举一反三了。
          1.PatternSet  即模式集合。顾名思义,就是定义一个模式,他可以用来指定一个文件集合。常常可以被外部的target引用,复用性很强。有includes、 includesfile、excludes、excludesfile属性。每个属性里面还可以嵌套name、if、unless等类型。
          2.DirSet  即目录集合。用来定义目录的集合。有dir、casesensitive、followsymlinks和PatternSet也有的那4个属性。上面说过PatternSet可以很好的复用。下面就是一个例子:
Xml代码
  1. <dirset dir="${build.dir}">  
  2.                <patternset id="non.test.classes">  
  3.                       <include name="apps/**/classes"/>  
  4.                        <exclude name="apps/**/*Test*"/>  
  5.                 </patternset>  
  6.  </dirset>  
<dirset dir="${build.dir}">
               <patternset id="non.test.classes">
                      <include name="apps/**/classes"/>
                       <exclude name="apps/**/*Test*"/>
                </patternset>
 </dirset>
 

        这是用patternset来定义DirSet的模式,这个模式还可以在外部引用。如:

Xml代码
  1. <dirset dir="{build.dir}">  
  2.                 <patternset refid="non.test.classes"/>  
  3. </dirset>  
  <dirset dir="{build.dir}">
                  <patternset refid="non.test.classes"/>
  </dirset>
 

          上面定义了一个名为non.test.classes的PatternSet,现在就可以引用他了。refid即reference ID.
          3.FileSet即文件集合,他的内部属性与DirSet几乎一样,只是多了一个file和defaultexcludes。和dirset一样,经常 嵌入patternset来定义文件集合;但是也有另外一个很常用的类型,叫selector,它并不是一个真正的类型或元素,只是一种、一类类型的统 称。如contains、date、depend、depth、different、filename、present、containsregexp、 size、type等。


文章来源:http://blog.163.com/ccbobo_cat/blog/static/3209946220096105521217
posted @ 2009-07-10 05:05 C.B.K 阅读(424) | 评论 (0)编辑 收藏
第一种方法:
mysql> GRANT SELECT,INSERT,UPDATE,DELETE,CREATE,DROP
-> ON <dbname>.*
-> TO <username>@<host name>
-> IDENTIFIED BY '<password>';

where <dbname> is the name of the database you are tyring to connect to, <username> is the username of the user trying to connect to the database, <host name> the name of the host (in your case the XXX host) and <password> the password of the user.
第二种方法:
通过客户端软件设置用户的主机以及权限,
message from server: Host 80dc58cd93cd4c3 is not allowed to connect to this MySQL server - ccbobo_cat - 落壁の蜘蛛Μ的博客message from server: Host 80dc58cd93cd4c3 is not allowed to connect to this MySQL server - ccbobo_cat - 落壁の蜘蛛Μ的博客

文章来源:http://blog.163.com/ccbobo_cat/blog/static/32099462200952925050579
posted @ 2009-06-29 14:51 C.B.K 阅读(1555) | 评论 (0)编辑 收藏

一、什么是条件变量

       与互斥锁不同,条件变量是用来等待而不是用来上锁的。条件变量用来自动阻塞一个线程,直到某特殊情况发生为止。通常条件变量和互斥锁同时使用。

       条件变量使我们可以睡眠等待某种条件出现。条件变量是利用线程间共享的全局变量进行同步的一种机制,主要包括两个动作:一个线程等待"条件变量的条件成立"而挂起;另一个线程使"条件成立"(给出条件成立信号)。

条 件的检测是在互斥锁的保护下进行的。如果一个条件为假,一个线程自动阻塞,并释放等待状态改变的互斥锁。如果另一个线程改变了条件,它发信号给关联的条件 变量,唤醒一个或多个等待它的线程,重新获得互斥锁,重新评价条件。如果两进程共享可读写的内存,条件变量可以被用来实现这两进程间的线程同步。

       使用条件变量之前要先进行初始化。可以在单个语句中生成和初始化一个条件变量如:

pthread_cond_t my_condition=PTHREAD_COND_INITIALIZER;(用于进程间线程的通信)。

也可以利用函数pthread_cond_init动态初始化。

 

二、条件变量函数

1

名称:

pthread_cond_init

目标:

条件变量初始化

头文件:

#include < pthread.h>

函数原形:

int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *attr);

参数:

cptr  条件变量

attr  条件变量属性

返回值:

成功返回0,出错返回错误编号。

     

 

 

 

 

 

  pthread_cond_init函数可以用来初始化一个条件变量。他使用变量attr所指定的属性来初始化一个条件变量,如果参数attr为空,那么它将使用缺省的属性来设置所指定的条件变量。

 

2.

名称:

pthread_cond_destroy

目标:

条件变量摧毁

头文件:

#include < pthread.h>

函数原形:

int pthread_cond_destroy(pthread_cond_t *cond);

参数:

cptr  条件变量

返回值:

成功返回0,出错返回错误编号。

      

 

 

 pthread_cond_destroy函数可以用来摧毁所指定的条件变量,同时将会释放所给它分配的资源。调用该函数的进程也并不要求等待在参数所指定的条件变量上。

 

3.

名称:

pthread_cond_wait/pthread_cond_timedwait

目标:

条件变量等待

头文件:

#include < pthread.h>

函数原形:

int pthread_cond_wait(pthread_cond_t *cond,pthread_mutex_t *mutex);

int pthread_cond_timedwait(pthread_cond_t *cond,pthread_mutex_t mytex,const struct timespec *abstime);

参数:

cond 条件变量

mutex 互斥锁

返回值:

成功返回0,出错返回错误编号。

      

 

 

 

 

 

 

第一个参数*cond是指向一个条件变量的指针。第二个参数*mutex则是对相关的互斥锁的指针。函数pthread_cond_timedwait函数类型与函数pthread_cond_wait,区别在于,如果达到或是超过所引用的参数*abstime,它将结束并返回错误ETIME.pthread_cond_timedwait函数的参数*abstime指向一个timespec结构。该结构如下:

typedef struct timespec{

       time_t tv_sec;

       long tv_nsex;

}timespec_t;

 

3.

名称:

pthread_cond_signal/pthread_cond_broadcast

目标:

条件变量通知

头文件:

#include < pthread.h>

函数原形:

int pthread_cond_signal(pthread_cond_t *cond);

int pthread_cond_broadcast(pthread_cond_t *cond);

参数:

cond 条件变量

返回值:

成功返回0,出错返回错误编号。

      

 

 

 

 

 参数*cond是对类型为pthread_cond_t 的一个条件变量的指针。当调用pthread_cond_signal时一个在相同条件变量上阻塞的线程将被解锁。如果同时有多个线程阻塞,则由调度策略确定接收通知的线程。如果调用pthread_cond_broadcast,则将通知阻塞在这个条件变量上的所有线程。一旦被唤醒,线程仍然会要求互斥锁。如果当前没有线程等待通知,则上面两种调用实际上成为一个空操作。如果参数*cond指向非法地址,则返回值EINVAL

 

下面是一个简单的例子,我们可以从程序的运行来了解条件变量的作用。

#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;/*
初始化互斥锁*/
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;/*
初始化条件变量*/

void *thread1(void *);
void *thread2(void *);

int i=1;
int main(void)
{
    pthread_t t_a;
    pthread_t t_b;

    pthread_create(&t_a,NULL,thread2,(void *)NULL);/*
创建进程t_a*/
    pthread_create(&t_b,NULL,thread1,(void *)NULL); /*
创建进程t_b*/
    pthread_join(t_b, NULL);/*
等待进程t_b结束*/
    pthread_mutex_destroy(&mutex);
    pthread_cond_destroy(&cond);
    exit(0);
}

void *thread1(void *junk)
{
    for(i=1;i<=9;i++)
    {
        pthread_mutex_lock(&mutex);/*
锁住互斥量*/
        if(i%3==0)
             pthread_cond_signal(&cond);/*
条件改变,发送信号,通知t_b进程*/
        else       
             printf("thead1:%d\n",i);
        pthread_mutex_unlock(&mutex);/*
解锁互斥量*/

sleep(1);
}

}

void *thread2(void *junk)
{
    while(i<9)
    {
        pthread_mutex_lock(&mutex);

if(i%3!=0)
            pthread_cond_wait(&cond,&mutex);/*
等待*/
        printf("thread2:%d\n",i);
        pthread_mutex_unlock(&mutex);

sleep(1);
}

}

程序创建了2个新线程使他们同步运行,实现进程t_b打印20以内3的倍数,t_a打印其他的数,程序开始线程t_b不满足条件等待,线程t_a运行使a循环加1并打印。直到i3的倍数时,线程t_a发送信号通知进程t_b,这时t_b满足条件,打印i值。

下面是运行结果:

#cc –lpthread –o cond cond.c

#./cond

thread1:1

thread1:2

thread2:3

thread1:4

thread1:5

thread2:6

thread1:7

thread1:8

thread2:9


文章来源:http://blog.163.com/ccbobo_cat/blog/static/3209946220095235658763
posted @ 2009-06-23 17:07 C.B.K 阅读(287) | 评论 (0)编辑 收藏
工具:grub4dos0.4.2(想要的给我发信,我发给你,loveitdoit@163.com)

文件:fedora7.0映像文件,可在网上下载。

过程:

1.解压缩grub4dos0.4.2,把里面的 grldr和menu.lst,文件复制到c盘根目录下。

2.fedora7.0映像文件不必解压,必须放在fat32的分区里。把里面的isolinux目录下

的VMLINUZ、INITRD.IMG解压到c盘根目录下。

3.在c:\下找到menu.lst,用记事本打开并修改,删除其他命令,添加以下命令!


title Linux System Install

kernel (hd0,0)/vmlinuz

initrd (hd0,0)/initrd.img


4.修改c:\boot.ini文件,在最后面添加c:\grldr="Start GRUB"并保存即可。

5.重起系统,选择Start GRUB,开始安装。

文章来源:http://blog.163.com/ccbobo_cat/blog/static/3209946220095234437396
posted @ 2009-06-23 16:05 C.B.K 阅读(137) | 评论 (0)编辑 收藏
花了半天时间研究了下下MYSQL的备份实现,发现其是在MY.CNF(MY.INI)配置文件中作的设置,直接设置服务器唯一性ID号加上其它的附加设 置,则可作为一台MASTER,而在 SLAVE机上,也只需要在配置文件中设置一下连接MASTER所需的参数即可,如果在MASTER里也加上连到SLAVE机的参数,则就是双向备份 了~~不过,这些连接参数中用到的账号需要注意权限的设置,否则会搞半天没反就急死你迪。。。
我在WIN上和LINUX上各装了MYSQL5,下面是它们的配置:
WIN(172.22.33.33)下的MASTER(由于我改了端口3327所以下面多加了个端口方面的特殊处理了)的配置(my.ini):(**一定要在mysqld配置段中配置,不象PHP,APACHE可以随便找个方便的地方配的,注意哈!!)

[mysqld]
#master 设置
server-id=1
log-bin=c:/masterlog
binlog-do-db=db5

#实现双机备份段,给MASTER同时加上SLAVE段,可选哈,如果不选,那就是WIN到LIN的主从备份

master-host=172.22.1.37
master-user=backup2
master-password=backup2
master-port=3306
master-connect-retry=60
replicate-do-db=db5

数据库中加一个账号:

GRANT FILE,REPLICATION SLAVE,REPLICATION CLIENT,SUPER ON *.*
TO [email=backup@]backup@'172.22.1.37'[/email] IDENTIFIED by 'backup';
这个权限表示,这个backup账号只能由从备份机172.22.1.37访问只能用来进行备份操作
LINUX(172.22.1.37)下的SLAVE机的配置(把安装目录里找到的任意一个*.cnf拷到/etc/my.cnf下进行修改):

server-id=2
#如果不需要双向备份下面两行可以不要
#否则还要加一个数据库用户账号
/*
GRANT FILE,REPLICATION SLAVE,REPLICATION CLIENT,SUPER ON *.*
TO [email=backup2@]backup2@'172.22.33.33'[/email] IDENTIFIED by 'backup2';
*/
log-bin=./masterlog
binlog-do-db=db5
#---------------------------------------
master-host=172.22.33.33
master-user=backup
master-password=backup
master-port=3327
master-connect-retry=60
replicate-do-db=db5
由于只是大概的弄了一下,特别是在数据库用户方面没有作仔细试验:),可能会有所不太准确的地方,还有就是,上面测试用到的数据库一定要是已经建立好并且 结构相同的,两台机子都重启后会进行检查,如果出现找不到或者检查到结构不同,会报错,最好就是在创建空数据库时或初始时安装两个一样的数据库后就建立好 关系,对于不同版本的MYSQL,官方说明也可以同步,但想一想,把MYSQL5 的数据备份到4中去丢失5的特性也没什么意义吧。。

文章来源:http://blog.163.com/ccbobo_cat/blog/static/32099462200952335921779
posted @ 2009-06-23 15:59 C.B.K 阅读(213) | 评论 (0)编辑 收藏

【第一篇】

我是如何提高口语水平的?


   首先、确定你自己的英语水平。中国大学毕业生的通病是,书面阅读还可以,口语不行,听力很差,书写凑合。但每个人具体情况又都不一样,有人阅读专业书一目 十行,但读报纸很费劲。有人听新闻可以,听别的不行。你必须首先了解自己,然后针对你的情况对症下药。这种评估工作最好找英语好的人帮你做,如果不方便, 只能自己评自己,就要尽量做到客观。

  其次、确定自己的发音水平。我有个朋友对我说他的发音没问题,可实际上他说得很多词我都听不懂。你学的是英国音还 是美国音都无所谓,反正最终从你嘴里出来的肯定是中国音。最重要的是发音要合理。英语每一个单词都有自己的念法,你不能凭空想象。比如,有人把 RESUME读做RE-'SOOM,这样,别人说RE-SIU-'MAY,你不知道是什么。你念RE-'SOOM,别人也听不懂。再次、确定自己的英语学 习目标。我这里仅把口语交流做为目标。最后、开始学习。

1、口语学习的关键是要模仿人家的说话。这包括语音和语调两部分。中国英语教学重视语调的很少,尽管很多时候语调可能比语音更重要。

2、买一台录音机,找一合磁带。根据你的水平,可以选择新概念第二或第三册,也可以到图书馆借一套有书和磁带的小故事集。注意:一定要有书,故事篇幅不能太长,生词量要小,过于简单没有关系。我倾向于使用故事,而不是对话或新闻听力材料。

3、进行跟读训练。放磁带,看着书,搞明白每一个单词的意思,理解整个故事情节。然后,放一句,暂停,学着人家读一句,然后,放下一句,暂停,再学一句,继续。

4、跟读过程中要注意的几点:

(1)一定要尽力模仿发音和语调,越象越好。

(2)开始时速度可以比较慢,要逐步使自己跟上人家的速度。

(3)中间可以回倒重放,但我倾向于让大家完成一小段后再回去重来。

5、同步阅读。当你对文章发音、语调完全掌握之后,就要在放录音的同时同步跟读。争取让自己的声音与他完全重合。注意语调和语音。如果中间有结巴的地方也不要紧,继续读下去,然后再回来重读。

6、关掉录音机,朗诵课文。注意使用学到的语音语调。带滚瓜烂熟之后,可以进入下一篇课文。

  这样,一两个月之后,当你“精读”过五到十篇约一千字篇幅的文章之后,你会发现你的英语发音和听力有了明显的进步。再配合其他学习,如与人聊天,看电视,听广播,等等,口语水平会得到显著提高。

【第二篇】

         英语作为一种工具,其实用性愈显重要。传统英语教育方法由于过于艰深化,以及盲目的应试模式使大部分的英语学习者学了几年甚至数十年,却仍然处于听不懂开不了口的尴尬境地。那么究竟如何才能在比较短的时间里快速提高口语水平,让她真正为你所用呢?
   西方最新流行一种外语学习理论,即口语提高的最好方式就是采用短期突破法。从下面的公式中,就可以看出,口语短期突破的方法是很有效的。
  口语提高速度定律=说英语时间/说中文时间Speed of learning English=Speaking English/Speaking Chinese ( in a period of time)
  比如,在给定的一天时间内(16小时),学生A练习英语口语的时间为14小时,说中文的时间为2小时,两者的比例为7:1;学生B练习口语的时间为2 小时英语,说中文的时间为14小时。比例为1:7。如此一来,学生A比学生B说英语的比例大49倍。
  我们认为:这一理论其实就是对语言学习规律一次很好的回归,语言的核心是使用者能够随时随地地使用它。你用的时间越长,你就越熟练,这里我们说的使用 就是“说”,用嘴巴表达出来,而不是用眼睛和脑子去看和死记。如果你能够在一段时间内的大部分时间里坚持持续使用英语而不是中文进行表达,把学习英语的任 务转化成母语似的说话习惯,你就完全可以在很短的时间内有效掌握一口流利的英语口语。
  当然现实情况却是:很多人并没有这样的勇气和能力去坚持使用一个完全不熟悉的语言进行日常的交流!所以选用一套优秀的教材和相应的工具就显得异常重要了,这种教材应该具备以下特点才能帮助你克服困难:
  1、能够随时随地学习,让你很容易就接触到英语;
  2、能够让你脱离书本,完全浸在英语环境里;
  3、内容应该精挑细选,具备典型性和代表性,帮助你在短时间内掌握精华内容,从而建立起长期学习的信心和基本能力。
  同时你应该注意培养自己的自信,学会勇敢犯错误,克服恐惧的心理障碍。其实这种心理障碍是成人自己加给自己的,为什么我们小时候学母语这么自然容易,就是因为那个时候不知道什么是丢脸。所以我们应该象小时候那样暂时忘却丢脸,勇敢地去丢脸!

【第三篇】

想提高英语口语水平,首先要在语音上下功夫:)~
下面是些方法,你可以根据自己的学习方式掌握:)~

1.其次,要有大量的阅读和听力做基础。在读和听的过程中,积累了词汇,掌握了句型,熟悉了用英语表达思想的方式,最重要的是培养了语感。

2.同时,学英语口语也需要用多种办法:如大声朗读英语对话和文章,朗读各种句型的例句和口语中最常用的句子,背诵文章及演讲,与会英语的人练口语,当 然,最好与以英语为母语的人练口语。事实上,自言自语亦是练习口语的有效的方法之一。如果你把自己说的英语给录制下来,听听自己的录音,若有问题,再加以 改正,效果就会更好。

3.说英语还要有胆量。如果你能在说不太出口,或是说不好的情况下,大胆地说。说上一段时间后,突然有一天你会自如、清楚地表达自己的思想。有了大胆说的精神,你才能闯过口语的难关。

4.只会学英语,而不能尽快地去用,那就永远也学不好英语。在学英语的过程中,要始终寻找机会说英语。比如说,你周围有几个喜欢说英语的朋友,大家在一起 就要用英语来交谈。这种交谈有利于每个人的英语学习,因为大家都有机会运用自己已掌握的英语知识来交流思想,巩固了已学的知识,并把知识转化成技能,同 时,还能从别人那儿学到新的东西。要想学好英语口语就要多说。

5.能同以英语为母语的人说英语是最佳方法。在国内学英语缺乏环境,看电影学英语口语是弥补环境不足的好方法。英语电影是一部英语国家的生活、文化、风俗 等一切的百科全书,是最全的英语口语百科全书。大量地看英文电影就是你彻底攻克英语“听”和“说”的法宝。英语电影把你带入了一个新的世界中去。你在电影 中,学到了英语口语的语汇、短语、句子结构,以及表达各种内容的说法。你要做的就是把自己想像成电影中的一个角色,在经历着自己的生活,又在经历着其他人 的生活。总之,看一部电影比在美国生活一天还好,看电影也能学到地道的英语口语。

【第四篇】

当代社会是个开放社会,信息社会,人们越来越重视交际,而我国改革开放的成功也日益提高了我国在世界上的地位,我们与世界各国交流的领域越来越广了,没有出众的英语口语表达将会寸步难行。
  而要提高英语口语表达能力,就要先了解英语口语表达的过程是怎样发生的。大家知道,语言是思维的外壳。口语表达的过程,实际上是一个复杂的心理和生理过程,是思维借助词语按一定句式迅速转换为有声言语的过程。因此,口语能力的强弱取决于:
  1、思维能力的强弱,特别是与口语有关的思维的条理性、敏锐性与灵活性,这是关键。
  2、准确、迅速地组织言语(选词、造句、组段、构篇)能力的强弱,这是基础。
  3、运用语言的能力的强弱,这是前提。
  根据口语表达循序渐进的一般规律,口语训练的重点应是培养敏锐的思维和强烈的语感。具体包括:
  1、语音。学会科学发声方法,能用准确、响亮、流畅的英语进行口头表达。
  2、语调。能借助声音高低升降、抑扬顿挫的变化来表达复杂的感情,掌握停连和轻重、抑扬和明暗、快慢和松紧等一般的朗读技巧。
  3、词汇。能掌握比较丰富的口语词汇。
  4、语脉。说话能做到有条有理、语言流畅、上下贯通、一脉相承。
  5、语境。说话注意目的、对象、场合,合乎规定情景的要求,讲礼貌、有针对性。懂得口语修辞。在会话中有随机应变的能力。
  此外,还要懂得口头言语的辅助手段--表情、姿势、动作等态势言语的运用。
  由于书面语和口语是相互渗透、相互促进的,为提高口语的表现力,可在说话训练之前先进行一章朗读、朗诵训练。听和说是一个事物的两个方面,吸收、表达 两者不能偏废,所以口语训练体系中也应包括。通过以上训练,掌握一定的朗读朗诵技巧,培养准确、流利、有感情地朗读朗诵一般作品的能力,特别注意培养强烈 的语感。
  3、听力训练
  培养听的注意力、理解力、记忆力和辨析力,提高听知能力,养成良好的听的习惯。
  4、口语表达基本方式训练
  进行叙述、描述、评述、解说等口语表达基本方式的训练,培养内部言语向外部言语迅速转化的能力,结合进行语调、语脉的训练。
  5、会话型言语训练
  言语形式有会话型和独白型两类。会话是指两个以上的人围绕一个或几个话题一起说话的形式,如交谈、座谈、辩论、审讯等。会话时参加者是互为听、讲者 的,因此后面的发言常常受到前面发言的制约。另外,由于当面交谈,大量态势语代替了言语表达,会话者的言语结构往往不严谨、不完善,省略句较多。
  可进行如下训练:通过交谈和辩论两种会话言语训练,了解它们的一般特点、注意事项,结合进行应变能力和礼貌用语的训练,从而在会话中有效地培养随机应变的能力。
  6、独白型言语训练
  独白是指一个人单独发言而其他人都作为听众的言语表达形式,如:讲故事、作报告、讲课、演讲、讲解员的解说等。独白言语一般不在进行过程中跟听众问答 交流,因此要求在事先要周密地了解听众的要求并系统地组织好发言内容和有关态势语。独白是一种高层次的言语形式。
  可通过讲故事和演讲两种独白言语的训练,了解它们的一般特点、注意事项,结合进行运用态势语的训练,这类训练很有利于培养思维的条理性和连贯性。
  7、即兴小品训练
  即兴小品要求表演者按照规定的题目和要求,在规定的时间内,充分发挥自己的想象,不用或少用道具,通过言语和动作的表演,展现社会生活中的某个瞬间或片断,表达一个简单的主题。
  严格地说,小品应该是话剧艺术表演训练的一种形式,但由于它具有综合的特点,对训练思维的创造性、敏捷性、条理性、言语表达的准确性、形象性、流畅 性,以及应变力,乃至姿势的综合运用等等,都有很大的好处,所以我们要想英语口语表达能力更上一个层次,这种形式的训练也要加以采用。
  懂得了英语口语表达的规律,并不等于就有了一口流畅的英语表达口才,就好象读了介绍游泳的书并不等于一定会游泳一样,关键还是要在长期的时实践中持之 以恒地艰苦磨练。这种训练不同于我们平时常听常说的那种日常英语口语训练。日常的英语口语训练与之相比简单得多,所用的词汇量及话题所涉及的深度都是相当 有限的。而真正高层次的英语口语交际所需达到的流畅性、条理性、敏锐性和灵活性并不是常练一些日常用语就能达到的,其中用到的词汇量也因话题的深入和多样 而大大增加了。
  所以,要想真正地提高英语口语,说一口流利而又有水平的交际英语,得有对英语口语表达感兴趣作为前提,懂得以上的规律,重视运用以上的训练步骤,加上 长期的艰苦训练,才会有成效,才会达到目的。听力训练,当然,在训练过程中,听和说是无法截然分开的。
  因此,英语口语训练体系可按以下顺序安排:
  1、语音训练
  在学习英语语音知识的基础上加强语音训练,进行方音辨正练习。通过学习,打好英语语音知识,有一定的辨音能力,能用英语正确、清楚、响亮地表达。
  2、朗读朗诵训练
  进行呼吸、发声与共鸣训练,吐字纳音的训练,以及各种朗读朗诵技巧的训练,学会常用文体的朗读、朗诵,懂得在朗诵中恰当使用态势语


文章来源:http://blog.163.com/ccbobo_cat/blog/static/3209946220095109201252
posted @ 2009-06-10 09:20 C.B.K 阅读(91) | 评论 (0)编辑 收藏

[关键字]:java,design pattern,设计模式,《Java与模式》,Chain of Responsibility,责任链模式
[环境]:StarUML5.0 + JDK6
[作者]:Winty (wintys@gmail.com)
[正文]:

package pattern.chainofresponsibility;

/**
 * 责任链模式:Chain of Responsibility
 * @version 2009-5-9
 * @author Winty(wintys@gmail.com)
 */
public class ChainOfResponsibilityTest{
    public static void main(String[] args){
        Handler handler1 = new ConcreteHandler1();
        Handler handler2 = new ConcreteHandler2();
        Handler handler3 = new ConcreteHandler3();

        //设置责任链
        handler3.setSuccessor(handler2);
        handler2.setSuccessor(handler1);

        //发送命令
        handler3.handleRequest();
    }
}

/**
 *抽象处理者
 */
abstract class Handler{
    protected Handler successor;

    public Handler getSuccessor(){
        return successor;
    }

    public void setSuccessor(Handler successor){
        this.successor = successor;
    }

    public abstract void handleRequest();
}

/**
 *具体处理者
 */
class ConcreteHandler1 extends Handler{
    public void handleRequest(){
        if(getSuccessor() != null){
            System.out.print("Request passed:from class Concrete1");
            System.out.println(" to class" + getSuccessor().getClass().getName());

            getSuccessor().handleRequest();
        }
        else{
            System.out.println("Request handled in ConcreteHandler1");
        }
    }
}

/**
 *具体处理者
 */
class ConcreteHandler2  extends Handler{
    public void handleRequest(){
        if(getSuccessor() != null){
            System.out.print("Request passed:from class Concrete2");
            System.out.println(" to class " + getSuccessor().getClass().getName());

            getSuccessor().handleRequest();
        }
        else{
            System.out.println("Request handled in ConcreteHandler2");
        }
    }
}

/**
 *具体处理者
 */
class ConcreteHandler3  extends Handler{
    public void handleRequest(){
        if(getSuccessor() != null){
            System.out.print("Request passed:from class Concrete3");
            System.out.println(" to class " + getSuccessor().getClass().getName());

            getSuccessor().handleRequest();
        }
        else{
            System.out.println("Request handled in ConcreteHandler3");
        }
    }
}

文章来源:http://blog.163.com/ccbobo_cat/blog/static/320994622009410264843
posted @ 2009-05-10 14:07 C.B.K 阅读(86) | 评论 (0)编辑 收藏