亚洲无mate20pro麻豆,亚洲AV成人片色在线观看高潮,亚洲高清中文字幕综合网

Wed, 01 Apr 2009 10:49:00 GMT

HibernateShard
    多数据库水��^分区解决�Ҏ��?

1. ��?/strong>
     Hibernate 的一个扩展，用于处理多数据库水��^分区架构�?
     由google工程�?2007�q?捐献�l?Hibernate�C�֌��?nbsp;
     http://www.hibernate.org/414.html
     目前版本�Q?nbsp; 3.0.0 beta2�Q?未发GA版�?
     条�g�Q�Hibernate Core 3.2, JDK 5.0

2. 水��^分区原理
     一个库表如 Order 存在于多个数据库实例上。按特定的分区逻辑�Q�将该库表的数据存储在这些实例中�Q�一条记录的主键 PK�Q�在所有实例中不得重复�?

    水��^分区在大型网站，大型企业应用中经帔R��用�?nbsp;�?a >www.sina.com.cn ,www.163.com www.bt285.cn www.guihua.org
    目的��Z��量数据分散存储�Q�分散操作，分散查询以便提高数据处理量和整体数据处理性能�?

    使用�Q?
      google工程师的设计�q�是非常好的�Q�完全兼�?Hibernate本��n的主要接口�?

Java代码

org.hibernate.Session
org.hibernate.SessionFactory
org.hibernate.Criteria
org.hibernate.Query

org.hibernate.Session org.hibernate.SessionFactory org.hibernate.Criteria org.hibernate.Query

     因此�E�序员开发变化不大，甚至不需要关心后��C��用了分区数据库。程序迁�U�问题不大。而且配置上比较简明�?

3. 三种�{�略�Q?/strong>
   1) ShardAccessStrategy, 查询操作�Ӟ��到那个分区执行�?
      默认提供两个实现�Q?
      ��序�{�略�Q�SequentialShardAccessStrategy�Q?每个query按顺序在所有分��Z��执行�?
      �q��{�略�Q�ParallelShardAccessStrategy�Q?每个query以多�U�程方式�q�发�q��的在所有分��Z��执行�?此策略下�Q�需要��用线�E�池机制满��特定的性能需要，java.util.concurrent.ThreadPoolExecutor�?

   2) ShardSelectionStrategy, 新增对象�Ӟ��存储到哪个分区�?
         框架默认提供了一个轮询选择�{�略 RoundRobinShardSelectionStrategy, 但一般不�q�样使用�?
        通常采用“attribute-based sharding”机制�Q�基于属性分区。一般是用户�Ҏ��表自己实��C��个基于属性分区的�{�略�c�ShardSelectionStrategy �Q�例如，以下WeatherReport��Z��continent属性选择分区�Q?

Java代码

  public class WeatherReportShardSelectionStrategy implements ShardSelectionStrategy {
public ShardId selectShardIdForNewObject(Object obj) {
    if(obj instanceof WeatherReport) {
        return ((WeatherReport)obj).getContinent().getShardId();
    }
    throw new IllegalArgumentException();
}

public class WeatherReportShardSelectionStrategy implements ShardSelectionStrategy { public ShardId selectShardIdForNewObject(Object obj) { if(obj instanceof WeatherReport) { return ((WeatherReport)obj).getContinent().getShardId(); } throw new IllegalArgumentException(); } }

   3) ShardResolutionStrategy, 该策略用于查扑֍�个对象时�Q�判断它在哪个或哪几个分��Z��?
      默认使用 AllShardsShardResolutionStrategy �Q�可以自定义例如�Q?

Java代码

public class WeatherReportShardResolutionStrategy extends AllShardsShardResolutionStrategy {
    public WeatherReportShardResolutionStrategy(List shardIds) {
        super(shardIds);
    }

    public List selectShardIdsFromShardResolutionStrategyData(
            ShardResolutionStrategyData srsd) {
        if(srsd.getEntityName().equals(WeatherReport.class.getName())) {
            return Continent.getContinentByReportId(srsd.getId()).getShardId();
        }
        return super.selectShardIdsFromShardResolutionStrategyData(srsd);
    }
}

public class WeatherReportShardResolutionStrategy extends AllShardsShardResolutionStrategy { public WeatherReportShardResolutionStrategy(List shardIds) { super(shardIds); } public List selectShardIdsFromShardResolutionStrategyData( ShardResolutionStrategyData srsd) { if(srsd.getEntityName().equals(WeatherReport.class.getName())) { return Continent.getContinentByReportId(srsd.getId()).getShardId(); } return super.selectShardIdsFromShardResolutionStrategyData(srsd); } }

4. 水��^分区下的查询

   对于��单查�?HibernateShard 可以满��?

   水��^分区下多库查询是一个挑战。主要存在于以下三种操作�Q?
   1) distinct
         因�ؓ需要遍历所有shard分区�Q��ƈ�q�行合�ƈ判断重复记录�?
   2) order by
         �c�M�� 1)
   3) aggregation
         count�Q�sim�Q�avg�{�聚合操作先分散到分区执行，再进行汇怅R�?
         是不是有点类��g�� MapReduce �Q?呵呵�?

   目前 HibernateShard 不支�?1), 2), �?3) 部分支持

    HibernateShard 目前通过 Criteria 接口的实现对聚合提供了较好的支持�Q?因�ؓ Criteria 以API接口指定�?Projection 操作�Q�逻辑相对��单�?

    而HQL�Q�原�?SQL �q�不支持此类操作�?


5. 再分区和虚拟分区
      当数据库规模增大�Q�需要调整分区逻辑和数据存储时�Q?需要再分区�?
      两种方式�Q?1�Q�数据库数据�q�移其他分区�Q?2�Q?改变记录和分区映��关�p�R��这两种方式都比较麻烦。尤�?#8220;改变记录和分区映��关�p?#8221;�Q�需要调�?ShardResolutionStrategy�?

     HibernateShard 提供了一�U�虚拟分区层。当需要调整分区策略时�Q�只需要调整虚拟分区和物理分区映射关系卛_��。以下是使用虚拟分区时的配置创徏�q�程�Q?

Java代码


  Map virtualShardMap = new HashMap();
virtualShardMap.put(0, 0);
virtualShardMap.put(1, 0);
virtualShardMap.put(2, 1);
virtualShardMap.put(3, 1);
ShardedConfiguration shardedConfig =
    new ShardedConfiguration(
        prototypeConfiguration,
        configurations,
        strategyFactory,
        virtualShardMap);
return shardedConfig.buildShardedSessionFactory();

Map virtualShardMap = new HashMap(); virtualShardMap.put(0, 0); virtualShardMap.put(1, 0); virtualShardMap.put(2, 1); virtualShardMap.put(3, 1); ShardedConfiguration shardedConfig = new ShardedConfiguration( prototypeConfiguration, configurations, strategyFactory, virtualShardMap); return shardedConfig.buildShardedSessionFactory();

6. 局限：
    1�Q�HibernateShard 不支持垂直分区，垂直+水��^混合分区�?

    2�Q?水��^分区�?查询功能受到一定限�Ӟ��有些功能不支持。实践中�Q�需要在应用层面�Ҏ��q�_��区算法进行更多的考虑�?
    3�Q?不支持跨分区�?关系操作。例如：删除A分区上的 s 表，B分区上的兌��子表 t的记录无法进行参照完整性约束检查�?�Q�其实这个相�?跨分区查询的挑战应该说小的多�Q�也许google工程师下个版本会支持�Q�呵呵）

    4) 解析�{�略接口��g��和对象ID全局唯一性有些自相矛盾，
AllShardsShardResolutionStrategy 的接口返回的是给定对象ID所在的 shard ID集合�Q�按理应该是明确的一�?shard ID.

参考资料：HibernateShard 参考指南�?

�?/a> 2009-04-01 18:49 发表评论

GPS�l�纬度可以用来Java解析

Thu, 26 Mar 2009 09:08:00 GMT
现在正开发的定位模块用到的定位设�|�是塞格车圣��D��讑֤��Q�发送指令返回的�l�纬度需要�{换成十进�Ӟ��再到GIS�pȝ��获取地理信息描述。以后需要要�l�常用到�q�方面的知识�Q�随�W�写下�?

��经�U�度转换成十�q�制

　公式�Q?br />     Decimal Degrees = Degrees + minutes/60 + seconds/3600
　　例：57°55'56.6" =57+55/60+56.6/3600=57.9323888888888

如把�l�纬�?nbsp; (longitude�Q�latitude) (205.395583333332�Q?7.9323888888888)转换据成坐标(Degrees,minutes,seconds)(205°23'44.1"�Q?7°55'56.6")�?/span>
步骤如下�Q?/span>

1�?直接��d��"�?�Q?span style="font-size: small">205

2�?205.395583333332-205)*60=23.734999999920 得到"�?�Q?span style="font-size: small">23

3�?23.734999999920-23)*60=44.099999995200 得到"�U?�Q?span style="font-size: small">44.1

发送定位指令，�l�端�q�回的经�U�度信息如下�Q?/span>

(ONE072457A3641.2220N11706.2569E000.000240309C0000400)

按照协议解析

获得信息体的�l�纬度是主要�Q�其它不要管�Q�直接用String�cȝ��substring()�Ҏ��截掉�Q�获取的�l�纬�?/span>

3641.2220N11706.2569E http://www.bt285.cn

Java代码

package com.tdt.test;

import com.tdt.api.gis.LocationInfo;

/**
*
Title:坐标转换

*
*
Description:

*
*
Copyright: Copyright (c) 2009

*
*
Company:

*
* @author sunnylocus
* @version 1.0 [2009-03-24]
*
*/
public class LonlatConversion {

    /**
     *
     * @param dms 坐标
     * @param type 坐标�c�d��
     * @return String 解析后的�l�纬�?
     */
    public static String xypase(String dms, String type) {
        if (dms == null || dms.equals("")) {
            return "0.0";
        }
        double result = 0.0D;
        String temp = "";

        if (type.equals("E")) {//�l�度
            String e1 = dms.substring(0, 3);//截取3位数字，�l�度�?位，最�?80�?
                                            //�l�度是一伦敦为点作南北两极的�U��ؓ0�?所有往西和往东各180�?nbsp;
            String e2 = dms.substring(3, dms.length());//需要运��的��数

            result = Double.parseDouble(e1);
            result += (Double.parseDouble(e2) / 60.0D);
            temp = String.valueOf(result);
            if (temp.length() > 9) {
                temp = e1 + temp.substring(temp.indexOf("."), 9);
            }
        } else if (type.equals("N")) {      //�U�度�Q�纬度是以赤道�ؓ基准,相当于把地球分两�?两个半球面上的点和��^面夹�?~90�?
            String n1 = dms.substring(0, 2);//截取2位，�U�度�?位，最�?0�?
            String n2 = dms.substring(2, dms.length());

            result = Double.parseDouble(n1);
            result += Double.parseDouble(n2) / 60.0D;
            temp = String.valueOf(result);
            if (temp.length() > 8) {
                temp = n1 + temp.substring(temp.indexOf("."), 8);
            }
        }
        return temp;
    }
    public static void main(String[] args) {
        String info="(ONE072457A3641.2220N11706.2569E000.000240309C0000400)";
        info=info.substring(11,info.length()-13);
        //�U�度
        String N = info.substring(0, info.indexOf("N"));
        //�l�度
        String E = info.substring(info.indexOf("N")+1,info.indexOf("E"));
        //��h��gis,获取地理信息描述
        double x = Double.parseDouble(CoordConversion.xypase(E,"E"));
        double y = Double.parseDouble(CoordConversion.xypase(N,"N"));
        String result =LocationInfo.getLocationInfo("test", x, y);　//System.out.println("径度:"+x+","+"�U�度:"+y);
        System.out.println(result);
    }
}

package com.tdt.test; import com.tdt.api.gis.LocationInfo; /** *
Title:坐标转换
* *
Description:
* *
Copyright: Copyright (c) 2009
* *
Company:
* * @author sunnylocus * @version 1.0 [2009-03-24] * */ public class LonlatConversion { /** * * @param dms 坐标 * @param type 坐标�c�d�� * @return String 解析后的�l�纬�? */ public static String xypase(String dms, String type) { if (dms == null || dms.equals("")) { return "0.0"; } double result = 0.0D; String temp = ""; if (type.equals("E")) {//�l�度 String e1 = dms.substring(0, 3);//截取3位数字，�l�度�?位，最�?80�? //�l�度是一伦敦为点作南北两极的�U��ؓ0�?所有往西和往东各180�? String e2 = dms.substring(3, dms.length());//需要运��的��数 result = Double.parseDouble(e1); result += (Double.parseDouble(e2) / 60.0D); temp = String.valueOf(result); if (temp.length() > 9) { temp = e1 + temp.substring(temp.indexOf("."), 9); } } else if (type.equals("N")) { //�U�度�Q�纬度是以赤道�ؓ基准,相当于把地球分两�?两个半球面上的点和��^面夹�?~90�? String n1 = dms.substring(0, 2);//截取2位，�U�度�?位，最�?0�? String n2 = dms.substring(2, dms.length()); result = Double.parseDouble(n1); result += Double.parseDouble(n2) / 60.0D; temp = String.valueOf(result); if (temp.length() > 8) { temp = n1 + temp.substring(temp.indexOf("."), 8); } } return temp; } public static void main(String[] args) { String info="(ONE072457A3641.2220N11706.2569E000.000240309C0000400 http://www.guihua.org )"; info=info.substring(11,info.length()-13); //�U�度 String N = info.substring(0, info.indexOf("N")); //�l�度 String E = info.substring(info.indexOf("N")+1,info.indexOf("E")); //��h��gis,获取地理信息描述 double x = Double.parseDouble(CoordConversion.xypase(E,"E")); double y = Double.parseDouble(CoordConversion.xypase(N,"N")); String result =LocationInfo.getLocationInfo("test", x, y);　//System.out.println("径度:"+x+","+"�U�度:"+y); System.out.println(result); } }

�q�行�l�果

在济南市�Q�位于轻骑�\和八涧堡路附�q�；在环保科技园国际商务中心和��南市区贤文庄附�q��?/div>

�?/a> 2009-03-26 17:08 发表评论

用Java来显�C�图片生成器

Mon, 23 Mar 2009 10:49:00 GMT

一、本囄��生成器具有以下功能特性：

     1、可以设�|�图片的宽度、高度、外框颜艌Ӏ�背景色�Q?/p>
     2、可以设�|�图片字体的大小、名�U�、颜�Ԍ��

     3、可以设�|�输出图片的格式�Q�如JPEG、GIF�{�；

     4、可以将囄��存储��C��个文件或者存储到一个输出流�Q?/p>
     5、可以�ؓ囄��增加若干条干扰线�Q�在生成随机码图片时可用此特性）�Q?/p>
     6、打印在囄��上的文字支持自动换行�Q?/p>

另外�Q�本囄��生成器还用到了模板方法模式�?/p>

二、下面列出相关的源代�?/p>
     1、抽象类AbstractImageCreator的源代码

/**本代码在 http://www.bt285.cn http://www.5a520.cn 已��用了 */

public abstract class AbstractImageCreator {
    private static Random rnd = new Random(new Date().getTime());

    //囄��宽度
    private int width = 200;

    //囄��高度
    private int height = 80;

    //外框颜色
    private Color rectColor;

    //背景�?
    private Color bgColor;

    //�q�扰�U�数�?
    private int lineNum = 0;

    //囄��格式
    private String formatName = "JPEG";

    //字体颜色
    private Color fontColor = new Color(0, 0, 0);

    //字体名称
    private String fontName = "宋体";

    //字体大小
    private int fontSize = 15;


    //##### �q�里省略成员变脸的get、set�Ҏ�� #####


    /**
     * ��d��扰线
     */
    private void drawRandomLine(Graphics graph){
        for(int i=0;i
            //�U�条的颜�?
            graph.setColor(getRandomColor(100, 155));

            //�U�条两端坐标�?
            int x1 = rnd.nextInt(width);
            int y1 = rnd.nextInt(height);

            int x2 = rnd.nextInt(width);
            int y2 = rnd.nextInt(height);

            //�ȝ��?
            graph.drawLine(x1, y1, x2, y2);
        }
    }

    /**
     * 随机获取颜色对象
     */
    private Color getRandomColor(int base, int range){
        if((base + range) > 255) range = 255 - base;

        int red = base + rnd.nextInt(range);
        int green = base + rnd.nextInt(range);
        int blue = base + rnd.nextInt(range);

        return new Color(red, green, blue);
    }

                //该方法内应用了模板方法模�?
    public void drawImage(String text)throws IOException{
        BufferedImage image = new BufferedImage(width, height, BufferedImage.TYPE_INT_RGB);

        if(rectColor == null) rectColor = new Color(0, 0, 0);
        if(bgColor == null) bgColor = new Color(240, 251, 200);

        //获取��d��
        Graphics graph = image.getGraphics();

        //画长方�Ş
        graph.setColor(bgColor);
        graph.fillRect(0, 0, width, height);

        //外框
        graph.setColor(rectColor);
        graph.drawRect(0, 0, width-1, height-1);

        //��d��扰线
        drawRandomLine(graph);

        //��d��W�串
        drawString(graph, text);

        //执行
        graph.dispose();

        //输出囄��l�果
        saveImage(image);
    }

    protected abstract void drawString(Graphics graph, String text);

    protected abstract void saveImage(BufferedImage image)throws IOException;

}

public abstract class AbstractImageCreator { private static Random rnd = new Random(new Date().getTime()); //囄��宽度 private int width = 200; //囄��高度 private int height = 80; //外框颜色 private Color rectColor; //背景�? private Color bgColor; //�q�扰�U�数�? private int lineNum = 0; //囄��格式 private String formatName = "JPEG"; //字体颜色 private Color fontColor = new Color(0, 0, 0); //字体名称 private String fontName = "宋体"; //字体大小 private int fontSize = 15; //##### �q�里省略成员变脸的get、set�Ҏ�� ##### /** * ��d��扰线 */ private void drawRandomLine(Graphics graph){ for(int i=0;i 255) range = 255 - base; int red = base + rnd.nextInt(range); int green = base + rnd.nextInt(range); int blue = base + rnd.nextInt(range); return new Color(red, green, blue); } //该方法内应用了模板方法模�? public void drawImage(String text)throws IOException{ BufferedImage image = new BufferedImage(width, height, BufferedImage.TYPE_INT_RGB); if(rectColor == null) rectColor = new Color(0, 0, 0); if(bgColor == null) bgColor = new Color(240, 251, 200); //获取��d�� Graphics graph = image.getGraphics(); //画长方�Ş graph.setColor(bgColor); graph.fillRect(0, 0, width, height); //外框 graph.setColor(rectColor); graph.drawRect(0, 0, width-1, height-1); //��d��扰线 drawRandomLine(graph); //��d��W�串 drawString(graph, text); //执行 graph.dispose(); //输出囄��l�果 saveImage(image); } protected abstract void drawString(Graphics graph, String text); protected abstract void saveImage(BufferedImage image)throws IOException; }

     2、类DefaultImageCreator的源代码

          该类��生成的囄��存储��C��个文件中�Q�需要设�|�outputFilePath成员变量��|��该成员变量��D��C�图片的存储全�\径�?/p>

Java代码

public class DefaultImageCreator extends AbstractImageCreator {
    private String outputFilePath;

    public String getOutputFilePath() {
        return outputFilePath;
    }

    public void setOutputFilePath(String outputFilePath) {
        this.outputFilePath = outputFilePath;
    }

    public DefaultImageCreator(){

    }

    public DefaultImageCreator(String outputFilePath){
        this.outputFilePath = outputFilePath;
    }

    @Override
    protected void drawString(Graphics graph, String text) {
        graph.setColor(getFontColor());
        Font font = new Font(getFontName(), Font.PLAIN, getFontSize());
        graph.setFont(font);

        FontMetrics fm = graph.getFontMetrics(font);
        int fontHeight = fm.getHeight(); //字符的高�?

        int offsetLeft = 0;
        int rowIndex = 1;
        for(int i=0;i
            char c = text.charAt(i);
            int charWidth = fm.charWidth(c); //字符的宽�?

            //另�v一�?
            if(Character.isISOControl(c) || offsetLeft >= (getWidth()-charWidth)){
                rowIndex++;
                offsetLeft = 0;
            }

            graph.drawString(String.valueOf(c), offsetLeft, rowIndex * fontHeight);
            offsetLeft += charWidth;
        }
    }

    @Override
    protected void saveImage(BufferedImage image)throws IOException{
        ImageIO.write(image, getFormatName(), new File(outputFilePath));
    }

}

public class DefaultImageCreator extends AbstractImageCreator { private String outputFilePath; public String getOutputFilePath() { return outputFilePath; } public void setOutputFilePath(String outputFilePath) { this.outputFilePath = outputFilePath; } public DefaultImageCreator(){ } public DefaultImageCreator(String outputFilePath){ this.outputFilePath = outputFilePath; } @Override protected void drawString(Graphics graph, String text) { graph.setColor(getFontColor()); Font font = new Font(getFontName(), Font.PLAIN, getFontSize()); graph.setFont(font); FontMetrics fm = graph.getFontMetrics(font); int fontHeight = fm.getHeight(); //字符的高�? int offsetLeft = 0; int rowIndex = 1; for(int i=0;i= (getWidth()-charWidth)){ rowIndex++; offsetLeft = 0; } graph.drawString(String.valueOf(c), offsetLeft, rowIndex * fontHeight); offsetLeft += charWidth; } } @Override protected void saveImage(BufferedImage image)throws IOException{ ImageIO.write(image, getFormatName(), new File(outputFilePath)); } }

     3、类OutputStreamImageCreator的源代码

         该类��生成的囄��存储��C��个输出流中，需要设�|�out成员变量倹{�?/p>

Java代码

public class OutputStreamImageCreator extends DefaultImageCreator {
    private OutputStream out ;

    public OutputStream getOut() {
        return out;
    }

    public void setOut(OutputStream out) {
        this.out = out;
    }

    public OutputStreamImageCreator(){

    }

    public OutputStreamImageCreator(OutputStream out){
        this.out = out;
    }

    @Override
    public String getOutputFilePath() {
        return null;
    }

    @Override
    public void setOutputFilePath(String outputFilePath) {
        outputFilePath = null;
    }

    @Override
    protected void saveImage(BufferedImage image) throws IOException {
        if(out!=null) ImageIO.write(image, getFontName(), out);
    }

}

public class OutputStreamImageCreator extends DefaultImageCreator { private OutputStream out ; public OutputStream getOut() { return out; } public void setOut(OutputStream out) { this.out = out; } public OutputStreamImageCreator(){ } public OutputStreamImageCreator(OutputStream out){ this.out = out; } @Override public String getOutputFilePath() { return null; } @Override public void setOutputFilePath(String outputFilePath) { outputFilePath = null; } @Override protected void saveImage(BufferedImage image) throws IOException { if(out!=null) ImageIO.write(image, getFontName(), out); } }

三、实例代�?/p>
     1、图片存储到文�g

StringBuffer sb = new StringBuffer();

sb.append("中华人民共和国\n");
sb.append("中华人民共和国\n");

DefaultImageCreator creator = new DefaultImageCreator("c:\\img.jpeg");
creator.setWidth(150);
creator.setHeight(100);
creator.setLineNum(60);
creator.setFontSize(20);
creator.drawImage(sb.toString());

StringBuffer sb = new StringBuffer(); sb.append("中华人民共和国\n"); sb.append("中华人民共和国\n"); DefaultImageCreator creator = new DefaultImageCreator("c:\\img.jpeg"); creator.setWidth(150); creator.setHeight(100); creator.setLineNum(60); creator.setFontSize(20); creator.drawImage(sb.toString());

�?/a> 2009-03-23 18:49 发表评论

Thu, 19 Mar 2009 04:51:00 GMT
Java�E�序的源代码很容易被别�h��L��Q�只要有一个反�~�译器，��M��人都可以分析别�h的代码。本文讨论如何在不修改原有程序的情况下，通过加密技术保护源代码�?
　　一、�ؓ什么要加密?

　　对于传统的C或C++之类的语�a�来说�Q�要在Web上保护源代码是很�Ҏ��的，只要不发布它��可以。遗憄��是，Java�E�序的源代码很容易被别�h��L��。只要有一个反�~�译器，��M��人都可以分析别�h的代码。Java的灵�z�L��得源代码很容易被�H�取�Q�但与此同时�Q�它也��通过加密保护代码变得相对�Ҏ��Q�我们唯一需要了解的��是Java的ClassLoader对象。当�Ӟ��在加密过�E�中�Q�有关Java Cryptography Extension(JCE)的知识也是必不可��的�?/p>
　　有几�U�技术可�?#8220;模糊”Java�c�L��Ӟ��使得反编译器处理�c�L��件的效果大打折扣。然而，修改反编译器使之能够处理�q�些�l�过模糊处理的类文�g�q�不是什么难事，所以不能简单地依赖模糊技术来保证源代码的安全�?/p>
　　我们可以用流行的加密工具加密应用�Q�比�?a >PGP(Pretty Good Privacy)或GPG(GNU Privacy Guard)。这�Ӟ��最�l�用户在�q�行应用之前必须先进行解密。但解密之后�Q�最�l�用户就有了一份不加密的类文�g�Q�这和事先不�q�行加密没有什么差别�?/p>
　　Java�q�行时装入字节码的机刉��含地意味着可以对字节码�q�行修改。JVM每次装入�c�L��件时都需要一个称为ClassLoader的对象，�q�个对象负责把新的类装入正在�q�行的JVM。JVM�l�ClassLoader一个包含了待装入类(比如java.lang.Object)名字的字�W�串�Q�然后由ClassLoader负责扑ֈ��c�L��Ӟ��装入原始数据�Q��ƈ把它转换成一个Class对象�?/p>
　　我们可以通过定制ClassLoader�Q�在�c�L��件执行之前修改它。这�U�技术的应用非常�q�泛??在这里，它的用途是在类文�g装入之时�q�行解密�Q�因此可以看成是一�U�即时解密器。由于解密后的字节码文�g永远不会保存到文件系�l�，所以窃密者很隑־�到解密后的代码�?/p>
　　�׃��把原始字节码转换成Class对象的过�E�完全由�pȝ��负责�Q�所以创建定制ClassLoader对象其实�q�不困难�Q�只需先获得原始数据，接着��可以进行包含解密在内的��M��转换�?/p>
　　Java 2在一定程度上��化了定制ClassLoader的构建。在Java 2中，loadClass的缺省实��C��旧负责处理所有必需的步骤，但�ؓ了顾及各�U�定制的�c�装入过�E�，它还调用一个新的findClass�Ҏ��?/p>
　　�q��ؓ我们�~�写定制的ClassLoader提供了一条捷径，减少了麻烦：只需覆盖findClass�Q�而不是覆盖loadClass。这�U�方法避免了重复所有装入器必需执行的公共步骤，因�ؓ�q�一切由loadClass负责�?/p>
　　不过�Q�本文的定制ClassLoader�q�不使用�q�种�Ҏ��。原因很��单。如果由默认的ClassLoader先寻扄��q�加密的�c�L��Ӟ��它可以找�?但由于类文�g已经加密�Q�所以它不会认可�q�个�c�L��Ӟ��装入�q�程��失败。因此，我们必须自己实现loadClass�Q�稍微增加了一些工作量�?/p>
二、定制类装入�?/strong>

　　每一个运行着的JVM已经拥有一个ClassLoader。这�?a >默认的ClassLoader�Ҏ��CLASSPATH环境变量的��|��在本地文件系�l�中��L��合适的字节码文件�?/p>
　　应用定制ClassLoader要求对这个过�E�有较�ؓ深入的认识。我们首先必��d��Z��个定制ClassLoader�cȝ��实例�Q�然后显式地要求它装入另外一个类。这��强制JVM把该�c�M��及所有它所需要的�c�d��联到定制的ClassLoader。Listing 1昄��了如何用定制ClassLoader装入�c�L��件�?/p>
　　【Listing 1�Q�利用定制的ClassLoader装入�c�L��件�?/p>
以下是引用片�D�：

　　// 首先创徏一个ClassLoader对象 �?http://www.bt285.cn
　　ClassLoader myClassLoader = new myClassLoader();
　　// 利用定制ClassLoader对象装入�c�L��?
　　// �q�把它�{换成Class对象
　　Class myClass = myClassLoader.loadClass( "mypackage.MyClass" );
　　// 最后，创徏该类的一个实�?
　　Object newInstance = myClass.newInstance();
　　// 注意�Q�MyClass所需要的所有其他类�Q�都��通过
　　// 定制的ClassLoader自动装入

　　如前所�q�ͼ�定制ClassLoader只需先获取类文�g的数据，然后把字节码传递给�q�行时系�l�，由后者完成余下的��d��?/p>
　　ClassLoader有几个重要的�Ҏ��。创建定制的ClassLoader�Ӟ��我们只需覆盖其中的一个，即loadClass�Q�提供获取原始类文�g数据的代码。这个方法有两个参数�Q�类的名字，以及一个表�C�JVM是否要求解析�c�d��字的标记(��x��否同时装入有依赖关系的类)。如果这个标记是true�Q�我们只需在返回JVM之前调用resolveClass�?/p>
　　【Listing 2�Q�ClassLoader.loadClass()的一个简单实现�?/p>
以下是引用片�D�：

public Class loadClass( String name, boolean resolve ) 如：http://www.5a520.cn
　　throws ClassNotFoundException {
　　try {
　　// 我们要创建的Class对象
　　Class clasz = null;
　　// 必需的步�?�Q�如果类已经在系�l�缓冲之中，
　　// 我们不必再次装入�?
　　clasz = findLoadedClass( name );
　　if (clasz != null)
　　return clasz;
　　// 下面是定刉��?
　　byte classData[] = /* 通过某种�Ҏ��获取字节码数�?*/;
　　if (classData != null) {
　　// 成功��d��字节码数据，现在把它转换成一个Class对象
　　clasz = defineClass( name, classData, 0, classData.length );
　　}
　　// 必需的步�?�Q�如果上面没有成功，
　　// 我们��试用默认的ClassLoader装入�?
　　if (clasz == null)
　　clasz = findSystemClass( name );
　　// 必需的步�?�Q�如有必要，则装入相关的�c?
　　if (resolve && clasz != null)
　　resolveClass( clasz );
　　// 把类�q�回�l�调用�?
　　return clasz;
　　} catch( IOException ie ) {
　　throw new ClassNotFoundException( ie.toString() );
　　} catch( GeneralSecurityException gse ) {
　　throw new ClassNotFoundException( gse.toString() );
　　}
　　}

    Listing 2昄��了一个简单的loadClass实现。代码中的大部分�Ҏ��有ClassLoader对象来说都一��P��但有一��部�?已通过注释标记)是特有的。在处理�q�程中，ClassLoader对象要用到其他几个辅助方法：
　　findLoadedClass�Q�用来进行检查，以便��认被请求的�c�d��前还不存在。loadClass�Ҏ��应该首先调用它�?/p>
　　defineClass�Q�获得原始类文�g字节码数据之后，调用defineClass把它转换成一个Class对象。�Q何loadClass实现都必��调用这个方法�?/p>
　　findSystemClass�Q�提供默认ClassLoader的支持。如果用来寻扄��的定制方法不能找到指定的�c?或者有意地不用定制�Ҏ��)�Q�则可以调用该方法尝试默认的装入方式。这是很有用的，特别是从普通的JAR文�g装入标准Java�c�L��?/p>
　　resolveClass�Q�当JVM惌��装入的不仅包括指定的�c�，而且�q�包括该�c�d��用的所有其他类�Ӟ��它会把loadClass的resolve参数讄��成true。这�Ӟ��我们必须在返回刚刚装入的Class对象�l�调用者之前调用resolveClass�?/p>
　　三、加密、解�?/strong>

　　Java加密扩展即Java Cryptography Extension�Q�简�U�JCE。它是Sun的加密服务��Y�Ӟ��包含了加密和密匙生成功能。JCE是JCA(Java Cryptography Architecture)的一�U�扩展�?/p>
　　JCE没有规定具体的加密算法，但提供了一个框�Ӟ��加密��法的具体实现可以作为服务提供者加入。除了JCE框架之外�Q�JCE软�g包还包含了SunJCE服务提供者，其中包括许多有用的加密算法，比如DES(Data Encryption Standard)和Blowfish�?/p>
　　为简单计�Q�在本文中我们将用DES��法加密和解密字节码。下面是用JCE加密和解密数据必��遵循的基本步骤�Q?/p>
　　步骤1�Q�生成一个安全密匙。在加密或解密�Q何数据之前需要有一个密匙。密匙是随同被加密的应用一起发布的一��段数据�Q�Listing 3昄��了如何生成一个密匙�?【Listing 3�Q�生成一个密匙�?/p>
以下是引用片�D�：

// DES��法要求有一个可信�Q的随机数�?
　　SecureRandom sr = new SecureRandom();
　　// 为我们选择的DES��法生成一个KeyGenerator对象
　　KeyGenerator kg = KeyGenerator.getInstance( "DES" );
　　kg.init( sr );
　　// 生成密匙
　　SecretKey key = kg.generateKey();
　　// 获取密匙数据
　　byte rawKeyData[] = key.getEncoded();
　　/* 接下来就可以用密匙进行加密或解密�Q�或者把它保�?
　　为文件供以后使用 */
　　doSomething( rawKeyData );

步骤2�Q�加密数据。得到密匙之后，接下来就可以用它加密数据。除了解密的ClassLoader之外�Q�一般还要有一个加密待发布应用的独立程�?见Listing 4)�?【Listing 4�Q�用密匙加密原始数据�?/p>
以下是引用片�D�：

// DES��法要求有一个可信�Q的随机数�?
　　SecureRandom sr = new SecureRandom();
　　byte rawKeyData[] = /* 用某�U�方法获得密匙数�?*/;
　　// 从原始密匙数据创建DESKeySpec对象
　　DESKeySpec dks = new DESKeySpec( rawKeyData );
　　// 创徏一个密匙工厂，然后用它把DESKeySpec转换�?
　　// 一个SecretKey对象
　　SecretKeyFactory keyFactory = SecretKeyFactory.getInstance( "DES" );
　　SecretKey key = keyFactory.generateSecret( dks );
　　// Cipher对象实际完成加密操作
　　Cipher cipher = Cipher.getInstance( "DES" );
　　// 用密匙初始化Cipher对象
　　cipher.init( Cipher.ENCRYPT_MODE, key, sr );
　　// 现在�Q�获取数据�ƈ加密
　　byte data[] = /* 用某�U�方法获取数�?*/
　　// 正式执行加密操作
　　byte encryptedData[] = cipher.doFinal( data );
　　// �q�一步处理加密后的数�?
　　doSomething( encryptedData );

　　步骤3�Q�解密数据。运行经�q�加密的应用�Ӟ��ClassLoader分析�q�解密类文�g。操作步骤如Listing 5所�C��?【Listing 5�Q�用密匙解密数据�?

　　// DES��法要求有一个可信�Q的随机数�?
　　SecureRandom sr = new SecureRandom();
　　byte rawKeyData[] = /* 用某�U�方法获取原始密匙数�?*/;
　　// 从原始密匙数据创��Z��个DESKeySpec对象
　　DESKeySpec dks = new DESKeySpec( rawKeyData );
　　// 创徏一个密匙工厂，然后用它把DESKeySpec对象转换�?
　　// 一个SecretKey对象
　　SecretKeyFactory keyFactory = SecretKeyFactory.getInstance( "DES" );
　　SecretKey key = keyFactory.generateSecret( dks );
　　// Cipher对象实际完成解密操作
　　Cipher cipher = Cipher.getInstance( "DES" );
　　// 用密匙初始化Cipher对象
　　cipher.init( Cipher.DECRYPT_MODE, key, sr );
　　// 现在�Q�获取数据�ƈ解密
　　byte encryptedData[] = /* 获得�l�过加密的数�?*/
　　// 正式执行解密操作
　　byte decryptedData[] = cipher.doFinal( encryptedData );
　　// �q�一步处理解密后的数�?
　　doSomething( decryptedData );

四、应用实�?/strong>

　　前面介绍了如何加密和解密数据。要部��v一个经�q�加密的应用�Q�步骤如下：

　　步骤1�Q�创建应用。我们的例子包含一个App�ȝ��Q�两个辅助类(分别�U�CؓFoo和Bar)。这个应用没有什么实际功用，但只要我们能够加密这个应用，加密其他应用也就不在话下�?/p>
　　步骤2�Q�生成一个安全密匙。在命��o行，利用GenerateKey工具(参见GenerateKey.java)把密匙写入一个文�Ӟ�� % java GenerateKey key.data

　　步骤3�Q�加密应用。在命��o行，利用EncryptClasses工具(参见EncryptClasses.java)加密应用的类�Q?% java EncryptClasses key.data App.class Foo.class Bar.class

　　该命令把每一�?class文�g替换成它们各自的加密版本�?/p>
　　步骤4�Q�运行经�q�加密的应用。用户通过一个DecryptStart�E�序�q�行�l�过加密的应用。DecryptStart�E�序如Listing 6所�C��?【Listing 6�Q�DecryptStart.java�Q�启动被加密应用的程序�?/p>
以下是引用片�D�：

　　import java.io.*;
　　import java.security.*;
　　import java.lang.reflect.*;
　　import javax.crypto.*;
　　import javax.crypto.spec.*;
　　public class DecryptStart extends ClassLoader
　　{
　　// �q�些对象在构造函��C��讄��Q?
　　// 以后loadClass()�Ҏ��利用它们解密类
　　private SecretKey key;
　　private Cipher cipher;
　　// 构造函敎ͼ�讄��解密所需要的对象
　　public DecryptStart( SecretKey key ) throws GeneralSecurityException,
　　IOException {
　　this.key = key;
　　String algorithm = "DES";
　　SecureRandom sr = new SecureRandom();
　　System.err.println( "[DecryptStart: creating cipher]" );
　　cipher = Cipher.getInstance( algorithm );
　　cipher.init( Cipher.DECRYPT_MODE, key, sr );
　　}
　　// main�q�程�Q�我们要在这里读入密匙，创徏DecryptStart�?
　　// 实例�Q�它��是我们的定制ClassLoader�?
　　// 讄��好ClassLoader以后�Q�我们用它装入应用实例，
　　// 最后，我们通过Java Reflection API调用应用实例的main�Ҏ��
　　static public void main( String args[] ) throws Exception {
　　String keyFilename = args[0];
　　String appName = args[1];
　　// �q�些是传递给应用本��n的参�?
　　String realArgs[] = new String[args.length-2];
　　System.arraycopy( args, 2, realArgs, 0, args.length-2 );
　　// ��d��密匙
　　System.err.println( "[DecryptStart: reading key]" );
　　byte rawKey[] = Util.readFile( keyFilename );
　　DESKeySpec dks = new DESKeySpec( rawKey );
　　SecretKeyFactory keyFactory = SecretKeyFactory.getInstance( "DES" );
　　SecretKey key = keyFactory.generateSecret( dks );
　　// 创徏解密的ClassLoader
　　DecryptStart dr = new DecryptStart( key );
　　// 创徏应用�ȝ��的一个实�?
　　// 通过ClassLoader装入�?
　　System.err.println( "[DecryptStart: loading "+appName+"]" );
　　Class clasz = dr.loadClass( appName );
　　// 最后，通过Reflection API调用应用实例
　　// 的main()�Ҏ��
　　// 获取一个对main()的引�?
　　String proto[] = new String[1];
　　Class mainArgs[] = { (new String[1]).getClass() };
　　Method main = clasz.getMethod( "main", mainArgs );
　　// 创徏一个包含main()�Ҏ��参数的数�l?
　　Object argsArray[] = { realArgs };
　　System.err.println( "[DecryptStart: running "+appName+".main()]" );
　　// 调用main()
　　main.invoke( null, argsArray );
　　}
　　public Class loadClass( String name, boolean resolve )
　　throws ClassNotFoundException {
　　try {
　　// 我们要创建的Class对象
　　Class clasz = null;
　　// 必需的步�?�Q�如果类已经在系�l�缓冲之�?
　　// 我们不必再次装入�?
　　clasz = findLoadedClass( name );
　　if (clasz != null)
　　return clasz;
　　// 下面是定刉��?
　　try {
　　// ��d��l�过加密的类文�g
　　byte classData[] = Util.readFile( name+".class" );
　　if (classData != null) {
　　// 解密...
　　byte decryptedClassData[] = cipher.doFinal( classData );
　　// ... 再把它�{换成一个类
　　clasz = defineClass( name, decryptedClassData,
　　0, decryptedClassData.length );
　　System.err.println( "[DecryptStart: decrypting class "+name+"]" );
　　}
　　} catch( FileNotFoundException fnfe )
　　// 必需的步�?�Q�如果上面没有成�?
　　// 我们��试用默认的ClassLoader装入�?
　　if (clasz == null)
　　clasz = findSystemClass( name );
　　// 必需的步�?�Q�如有必要，则装入相关的�c?
　　if (resolve && clasz != null)
　　resolveClass( clasz );
　　// 把类�q�回�l�调用�?
　　return clasz;
　　} catch( IOException ie ) {
　　throw new ClassNotFoundException( ie.toString()
　　);
　　} catch( GeneralSecurityException gse ) {
　　throw new ClassNotFoundException( gse.toString()
　　);
　　}
　　}
　　}

对于未经加密的应用，正常执行方式如下�Q?% java App arg0 arg1 arg2

　　对于�l�过加密的应用，则相应的�q�行方式为： % java DecryptStart key.data App arg0 arg1 arg2

　　DecryptStart有两个目的。一个DecryptStart的实例就是一个实施即时解密操作的定制ClassLoader;同时�Q�DecryptStart�q�包含一个main�q�程�Q�它创徏解密器实例�ƈ用它装入和运行应用。示例应用App的代码包含在App.java、Foo.java和Bar.java内。Util.java是一个文件I/O工具�Q�本文示例多处用��C��它。完整的代码请从本文最后下载�?/p>
　　五、注意事��?/strong>

　　我们看到�Q�要在不修改源代码的情况下加密一个Java应用是很�Ҏ��的。不�q�，世上没有完全安全的系�l�。本文的加密方式提供了一定程度的源代码保护，但对某些��d��来说它是脆弱的�?/p>
　　虽然应用本��n�l�过了加密，但启动程序DecryptStart没有加密。攻击者可以反�~�译启动�E�序�q�修改它�Q�把解密后的�c�L��件保存到��盘。降低这�U�风险的办法之一是对启动�E�序�q�行高质量的模糊处理。或者，启动�E�序也可以采用直接编译成机器语言的代码，使得启动�E�序��h��传统执行文�g格式的安全性�?/p>
　　另外�q�要��C��的是�Q�大多数JVM本��n�q�不安全。狡猄��黑客可能会修改JVM�Q�从ClassLoader之外获取解密后的代码�q�保存到��盘�Q�从而绕�q�本文的加密技术。Java没有为此提供真正有效的补救措施�?/p>
　　不过应该指出的是�Q�所有这些可能的��d��都有一个前提，�q�就是攻击者可以得到密匙。如果没有密匙，应用的安全性就完全取决于加密算法的安全性。虽然这�U�保护代码的�Ҏ��U�C��上十全十��，但它仍不�׃ؓ一�U�保护知识��权和敏感用户数据的有效方案�?/p>

�?/a> 2009-03-19 12:51 发表评论

java中的io�W�记

Wed, 18 Mar 2009 11:10:00 GMT
Java ��在处理上分为字�W�流和字节流。字�W�流处理的单元�ؓ 2 个字节的 Unicode 字符�Q�分别操作字�W�、字�W�数�l�或字符�Ԍ��而字节流处理单元�?1 个字节，操作字节和字节数�l��?
Java 内用 Unicode �~�码存储字符�Q�字�W�流处理�c�负责将外部的其他编码的字符��和 java �?Unicode 字符��之间的转换。而类 InputStreamReader �?OutputStreamWriter 处理字符��和字节��的转换。字�W�流�Q�一�ơ可以处理一个缓冲区�Q�一�ơ操作比字节��（一�ơ一个字节）效率高�?nbsp;

( 一 )以字节�ؓ导向�?stream------InputStream/OutputStream

InputStream �?OutputStream 是两�?abstact �c�，对于字节为导向的 stream 都扩展这两个鸡肋�Q�基�c?^_^ �Q?;

1�?InputStream

1.1

ByteArrayInputStream -- 把内存中的一个缓冲区作�ؓ InputStream 使用 . 如��?a >http://www.5a520.cn

construct---

(A)ByteArrayInputStream(byte[]) 创徏一个新字节数组输入��（ ByteArrayInputStream �Q�，它从指定字节数组中读取数据（使用 byte 作�ؓ其缓冲区数组�Q?

(B)---ByteArrayInputStream(byte[], int, int) 创徏一个新字节数组输入��，它从指定字节数组中读取数据�?

---mark:: 该字节数�l�未被复制�?

1.2

StringBufferInputStream -- 把一�?String 对象作�ؓ InputStream .

construct---

StringBufferInputStream(String) 据指定串创徏一个读取数据的输入��串�?

注释�Q�不推荐使用 StringBufferInputStream �Ҏ��?此类不能��字�W�正��的转换为字节�?

�?JDK 1.1 版中的类��|��从一个串创徏一个流的最��x��法是采用 StringReader �c�R�?

1.3

FileInputStream -- 把一个文件作�?InputStream �Q�实现对文�g的读取操�?

construct---

(A)FileInputStream(File name) 创徏一个输入文件流�Q�从指定�?File 对象��d��数据�?

(B)FileInputStream(FileDescriptor) 创徏一个输入文件流�Q�从指定的文件描�q�器��d��数据�?

(C)-FileInputStream(String name) 创徏一个输入文件流�Q�从指定名称的文件读取数据�?

method ---- read() 从当前输入流中读取一字节数据�?

read(byte[]) ��当前输入流�?b.length 个字节数据读��C��个字节数�l�中�?

read(byte[], int, int) ��输入流�?len 个字节数据读入一个字节数�l�中�?

1.4

PipedInputStream �Q�实��C�� pipe 的概念，主要在线�E�中使用 . ��道输入��是指一个通讯��道的接收端�?

一个线�E�通过��道输出��发送数据，而另一个线�E�通过��道输入��读取数据，�q�样可实��C��个线�E�间的通讯�?

construct---

PipedInputStream() 创徏一个管道输入流�Q�它�q�未与一个管道输出流�q�接�?

PipedInputStream(PipedOutputStream) 创徏一个管道输入流 , 它已�q�接��C��个管道输出流�?

1.5

SequenceInputStream �Q�把多个 InputStream 合�ƈ��Z��?InputStream . “序列输入��?#8221;�c�d��许应用程序把几个输入��连�l�地合�ƈ��h��Q?

�q�且使它们像单个输入��一样出现。每个输入流依次被读取，直到到达该流的末��?

然后“序列输入��?#8221;�c�d��闭这个流�q�自动地切换��C��一个输入流�?

construct---

SequenceInputStream(Enumeration) 创徏一个新的序列输入流�Q��ƈ用指定的输入��的枚�D值初始化它�?

SequenceInputStream(InputStream, InputStream) 创徏一个新的序列输入流�Q�初始化为首�?读输入流 s1, 然后读输入流 s2 �?

2�?OutputSteam http://www.bt285.cn

2.1

ByteArrayOutputStream �Q?把信息存入内存中的一个缓冲区�?. 该类实现一个以字节数组形式写入数据的输出流�?

当数据写入缓冲区�Ӟ��它自动扩大。用 toByteArray() �?toString() 能检索数据�?

constructor

(A)--- ByteArrayOutputStream() 创徏一个新的字节数�l�输出流�?

(B)--- ByteArrayOutputStream() 创徏一个新的字节数�l�输出流�?

(C)--- ByteArrayOutputStream(int) 创徏一个新的字节数�l�输出流�Q��ƈ带有指定大小字节的缓冲区定w��?

toString(String) �Ҏ��指定字符�~�码��缓冲区内容转换为字�W�串�Q��ƈ��字节�{换�ؓ字符�?

write(byte[], int, int) ��指定字节数�l�中从偏�U�量 off 开始的 len 个字节写入该字节数组输出��?

write(int) ��指定字节写入该字节数组输出��?

writeTo(OutputStream) �?out.write(buf, 0, count) 调用输出��的写方法将该字节数�l�输出流的全部内容写入指定的输出��参数�?

2.2

FileOutputStream: 文�g输出��是�?File �?FileDescriptor 输出数据的一个输出流�?

constructor

(A)FileOutputStream(File name) 创徏一个文件输出流�Q�向指定�?File 对象输出数据�?

(B)FileOutputStream(FileDescriptor) 创徏一个文件输出流�Q�向指定的文件描�q�器输出数据�?

(C)FileOutputStream(String name) 创徏一个文件输出流�Q�向指定名称的文件输出数据�?

(D)FileOutputStream(String, boolean) 用指定系�l�的文�g名，创徏一个输出文件�?

2.3

PipedOutputStream: ��道输出��是指一个通讯��道的发送端�?一个线�E�通过��道输出��发送数据，

而另一个线�E�通过��道输入��读取数据，�q�样可实��C��个线�E�间的通讯�?

constructor

(A)PipedOutputStream() 创徏一个管道输出流�Q�它�q�未与一个管道输入流�q�接�?

(B)PipedOutputStream(PipedInputStream) 创徏一个管道输出流�Q�它已连接到一个管道输入流�?

( �?)以字�W��ؓ导向�?stream Reader/Writer

�?Unicode 字符为导向的 stream �Q�表�C�Z�� Unicode 字符为单位从 stream 中读取或往 stream 中写入信息�?

Reader/Writer �?abstact �c?

�?Unicode 字符为导向的 stream 包括下面几种�c�d��Q?

1. Reader

1.1

CharArrayReader �Q�与 ByteArrayInputStream 对应此类实现一个可用作字符输入��的字符�~�冲�?

constructor

CharArrayReader(char[]) 用指定字�W�数�l�创��Z��?CharArrayReader �?

CharArrayReader(char[], int, int) 用指定字�W�数�l�创��Z��?CharArrayReader

1.2

StringReader �Q?�?StringBufferInputStream 对应其源��Z��个字�W�串的字�W�流�?

StringReader(String) 创徏一新的串读取者�?/p>
1.3

FileReader �Q?�?FileInputStream 对应

1.4

PipedReader �Q�与 PipedInputStream 对应

2. Writer

2.1 CharArrayWrite �Q?�?ByteArrayOutputStream 对应

2.2   StringWrite �Q�无与之对应的以字节为导向的 stream

2.3 FileWrite �Q?�?FileOutputStream 对应

2.4 PipedWrite �Q�与 PipedOutputStream 对应

3、两�U�不同导向的 stream 之间的�{�?nbsp;

3.1

InputStreamReader �?OutputStreamReader �Q?

把一个以字节为导向的 stream 转换成一个以字符为导向的 stream �?

InputStreamReader �c�L��从字节流到字�W�流的桥梁：它读入字节，�q�根据指定的�~�码方式�Q�将之�{换�ؓ字符��?

使用的编码方式可能由名称指定�Q�或�q�_��可接受的�~�省�~�码方式�?

InputStreamReader �?read() �Ҏ��之一的每�ơ调用，可能促��从基本字节输入流中读取一个或多个字节�?

��Z��辑ֈ�更高效率�Q�考虑�?BufferedReader ��装 InputStreamReader �Q?

BufferedReader in = new BufferedReader(new InputStreamReader(System.in));

例如�Q?// 实现从键盘输入一个整�?

view plain copy to clipboard print ?

String s = null;
InputStreamReader re = new InputStreamReader(System.in);
              BufferedReader br = new BufferedReader(re);
              try {
              s = br.readLine();
              System.out.println("s= " + Integer.parseInt(s));
              br.close();
              }
              catch (IOException e)
              {
              e.printStackTrace();
              }
              catch (NumberFormatException e)// 当应用程序试囑ְ�字符串�{换成一�U�数值类型，但该字符串不能�{换�ؓ适当格式�Ӟ��抛出该异常�?
              {
              System.out.println(" 输入的不是数�?nbsp;");
              }

String s = null; InputStreamReader re = new InputStreamReader(System.in); BufferedReader br = new BufferedReader(re); try { s = br.readLine(); System.out.println("s= " + Integer.parseInt(s)); br.close(); } catch (IOException e) { e.printStackTrace(); } catch (NumberFormatException e)// 当应用程序试囑ְ�字符串�{换成一�U�数值类型，但该字符串不能�{换�ؓ适当格式�Ӟ��抛出该异常�? { System.out.println(" 输入的不是数�?"); }

InputStreamReader(InputStream) 用缺省的字符�~�码方式�Q�创��Z��?InputStreamReader �?

InputStreamReader(InputStream, String) 用已命名的字�W�编码方式，创徏一�?InputStreamReader �?

OutputStreamWriter ��多个字�W�写入到一个输出流�Q�根据指定的字符�~�码��多个字�W��{换�ؓ字节�?

每个 OutputStreamWriter 合�ƈ它自��q�� CharToByteConverter, 因而是从字�W�流到字节流的桥梁�?/p>

�Q�三�Q�Java IO 的一般��用原�?�Q?nbsp;

一、按数据来源�Q�去向）分类�Q?

1 、是文�g�Q?FileInputStream, FileOutputStream, ( 字节��?)FileReader, FileWriter( 字符 )

2 、是 byte[] �Q?ByteArrayInputStream, ByteArrayOutputStream( 字节��?)

3 、是 Char[]: CharArrayReader, CharArrayWriter( 字符��?)

4 、是 String: StringBufferInputStream, StringBufferOuputStream ( 字节��?)StringReader, StringWriter( 字符��?)

5 、网�l�数据流�Q?InputStream, OutputStream,( 字节��?) Reader, Writer( 字符��?)

二、按是否格式化输出分�Q?

1 、要格式化输出： PrintStream, PrintWriter

三、按是否要缓冲分�Q?

1 、要�~�冲�Q?BufferedInputStream, BufferedOutputStream,( 字节��?) BufferedReader, BufferedWriter( 字符��?)

四、按数据格式分：

1 、二�q�制格式�Q�只要不能确定是�U�文本的�Q?: InputStream, OutputStream 及其所有带 Stream �l�束的子�c?

2 、纯文本格式�Q�含�U�英文与汉字或其他编码方式）�Q?Reader, Writer 及其所有带 Reader, Writer 的子�c?

五、按输入输出分：

1 、输入： Reader, InputStream �c�d��的子�c?

2 、输出： Writer, OutputStream �c�d��的子�c?

六、特�D�需要：

1 、从 Stream �?Reader,Writer 的�{换类�Q?InputStreamReader, OutputStreamWriter

2 、对象输入输出： ObjectInputStream, ObjectOutputStream

3 、进�E�间通信�Q?PipeInputStream, PipeOutputStream, PipeReader, PipeWriter

4 、合�q�输入： SequenceInputStream

5 、更�Ҏ��的需要： PushbackInputStream, PushbackReader, LineNumberInputStream, LineNumberReader

军_��使用哪个�c�M��及它的构造进�E�的一般准则如下（不考虑�Ҏ��需要）�Q?

首先�Q�考虑最原始的数据格式是什么：原则�?

�W�二�Q�是输入�q�是输出�Q�原则五

�W�三�Q�是否需要�{换流�Q�原则六�W?1 �?

�W�四�Q�数据来源（��d��Q�是什么：原则一

�W�五�Q�是否要�~�冲�Q�原则三 �Q�特别注明：一定要注意的是 readLine() 是否有定义，有什么比 read, write 更特�D�的输入或输出方法）

�W�六�Q�是否要格式化输出：原则�?

�?/a> 2009-03-18 19:10 发表评论

Thu, 12 Mar 2009 12:16:00 GMT
早上帮朋友一台服务器解决�?Mysql cpu 占用 100% 的问题。稍整理了一下，��经验记录在�q�篇文章�?
　　朋友��L��(Windows 2003 + IIS + PHP + MYSQL )�q�来 MySQL 服务�q�程 (mysqld-nt.exe) CPU 占用率��Mؓ 100% 高居不下。此��L��?0个左右的 database, 分别�l�十个网站调用。据朋友��试�Q�导�?mysqld-nt.exe cpu 占用奇高的是�|�站A�Q�一旦在 IIS 中将此网站停止服务，CPU 占用��降下来了。一启用�Q�则马上上升�?/p>
　MYSQL CPU 占用 100% 的解册��E?/h2>
　　今天早上仔细��查了一下。目前此��说�|�站 http://www.5a520.cn 的七日��^均日 IP �?000�Q�PageView �?3万左叟뀂网站A 用的 database 目前�?9个表�Q�记录数 60.1万条�Q�占�I�间 45MB。按�q�个数据�Q�MySQL 不可能占用这么高的资源�?/p>
　　于是在服务器上运行命令，��?mysql 当前�?strong>环境变量输出到文�?output.txt�Q?/p>
d:\web\mysql> mysqld.exe --help >output.txt

　　发现 tmp_table_size 的值是默认�?32M�Q�于是修�?My.ini, ��?tmp_table_size 赋值到 200M:

d:\web\mysql> notepad c:\windows\my.ini [mysqld] tmp_table_size=200M

　　然后重启 MySQL 服务。CPU 占用有轻微下降，以前的CPU 占用波�Ş图是 100% 一根直�U�，现在则在 97%~100%之间起伏。这表明调整 tmp_table_size 参数�?MYSQL 性能提升有改善作�?/strong>。但问题�q�没有完全解冟�?/p>
　　于是�q�入 mysql �?shell 命��o行，调用 show processlist, 查看当前 mysql 使用频繁�?sql 语句�Q?/p>
mysql> show processlist;

　　反复调用此命令，发现�|�站 A 的两�?SQL 语句�l�常�?process list 中出玎ͼ�其语法如下：

SELECT t1.pid, t2.userid, t3.count, t1.date FROM _mydata AS t1 LEFT JOIN _myuser AS t3 ON t1.userid=t3.userid LEFT JOIN _mydata_body AS t2 ON t1.pid=t3.pid ORDER BY t1.pid LIMIT 0,15

　　调用 show columns ��查这三个表的�l�构 :

mysql> show columns from _myuser; mysql> show columns from _mydata; mysql> show columns from _mydata_body;

　　�l�于发现了问题所在：_mydata 表，只根�?pid 建立了一�?primary key�Q�但�q�没有�ؓ userid 建立索引。而在�q�个 SQL 语句的第一�?LEFT JOIN ON 子句中：

LEFT JOIN _myuser AS t3 ON t1.userid=t3.userid

　　_mydata �?userid 被参与了条�g比较�q�算。于是我为给 _mydata 表根据字�D?userid 建立了一个烦引：

mysql> ALTER TABLE `_mydata` ADD INDEX ( `userid` )

　　建立此烦引之后，CPU 马上降到�?80% 左右。看到找��C��问题所在，于是��查另一个反复出现在 show processlist 中的 sql 语句�Q?/p>
SELECT COUNT(*) FROM _mydata AS t1, _mydata_key AS t2 WHERE t1.pid=t2.pid and t2.keywords = '孔雀'

　　�l�检�?_mydata_key 表的�l�构�Q�发现它只�ؓ pid ��Z��?primary key, 没有�?keywords 建立 index。_mydata_key 目前�?33 万条记录�Q�在没有索引的情况下�?3万条记录�q�行文本��索匹配，不耗费大量�?cpu 旉��才怪。看来就是针对这个表的检索出问题了。于是同样�ؓ _mydata_key 表根据字�D?keywords 加上索引:

mysql> ALTER TABLE `_mydata_key` ADD INDEX ( `keywords` )

　　建立此烦引之后，CPU立刻降了下来�Q�在 50%~70%之间震荡�?/p>
　　再次调用 show prosslist�Q�网站A 的sql 调用��很��出现在�l�果列表中了。但发现此主��行了几个 Discuz 的论坛程序， Discuz 论坛的好几个表也存在着�q�个问题。于是顺手一�q�解冻I��cpu占用再次降下来了

　解决 MYSQL CPU 占用 100% 的经验�ȝ��

　　 http://www.bt285.cn BT下蝲

增加 tmp_table_size �?/strong>。mysql 的配�|�文件中�Q?strong>tmp_table_size 的默认大��是 32M。如果一张��时表��出该大��，MySQL产生一�?The table tbl_name is full 形式的错误，如果你做很多高�� GROUP BY 查询�Q?strong>增加 tmp_table_size �?/strong>�?�q�是 mysql 官方关于此选项的解释：

tmp_table_size

This variable determines the maximum size for a temporary table in memory. If the table becomes too large, a MYISAM table is created on disk. Try to avoid temporary tables by optimizing the queries where possible, but where this is not possible, try to ensure temporary tables are always stored in memory. Watching the processlist for queries with temporary tables that take too long to resolve can give you an early warning that tmp_table_size needs to be upped. Be aware that memory is also allocated per-thread. An example where upping this worked for more was a server where I upped this from 32MB (the default) to 64MB with immediate effect. The quicker resolution of queries resulted in less threads being active at any one time, with all-round benefits for the server, and available memory.

�?WHERE, JOIN, MAX(), MIN(), ORDER BY �{�子句中的条件判断中用到的字�D?应该�Ҏ��其徏立烦�?INDEX。烦引被用来快速找出在一个列上用一特定值的行。没有烦引，MySQL不得不首先以�W�一条记录开始�ƈ然后��d��整个表直到它扑և�相关的行。表��大�Q�花�Ҏ��间越多。如果表对于查询的列有一个烦引，MySQL能快速到达一个位�|�去搜寻到数据文件的中间�Q�没有必要考虑所有数据。如果一个表�?000行，�q�比��序��d��臛_��?00倍。所有的MySQL索引(PRIMARY、UNIQUE和INDEX)在B树中存储�?

�Ҏ�� mysql 的开发文�?

索引 index 用于�Q?

快速找出匹配一个WHERE子句的行
当执行联�l?JOIN)�Ӟ��从其他表��索行�?
对特定的索引列找出MAX()或MIN()�?
如果排序或分�l�在一个可用键的最左面前缀上进�?例如�Q�ORDER BY key_part_1,key_part_2)�Q�排序或分组一个表。如果所有键值部分跟随DESC�Q�键以倒序被读取�?
在一些情况中�Q�一个查询能被优化来��索��|��不用咨询数据文�g。如果对某些表的所有��用的列是数字型的�q�且构成某些键的最左面前缀�Q��ؓ了更快，值可以从索引树被��索出来�?br />
假定你发��Z��列SELECT语句�Q?

mysql> SELECT * FROM tbl_name WHERE col1=val1 AND col2=val2;
如果一个多列烦引存在于col1和col2上，适当的行可以直接被取出。如果分开的单行列索引存在于col1和col2上，优化器试��N��过军_��哪个索引��找到更��的行�ƈ来找出更具限制性的索引�q�且使用该烦引取行�?

　　开发�h员做 SQL 数据表设计的时候，一定要通盘考虑清楚�?

�?/a> 2009-03-12 20:16 发表评论

使用org.apache.commons.net.ftp包开发FTP客户端，实现�q�度汇报�Q�实现断点箋传，中文支持

Tue, 10 Mar 2009 08:34:00 GMT
     摘要: 利用org.apache.commons.net.ftp包实��C��个简单的ftp客户端实用类。主要实��C��下功�?1.支持上传下蝲。支持断点箋�?2.支持�q�度汇报 3.支持对于中文目录及中文文件创建的支持�?import java.io.File;    import java.io.FileOutputStream;  ...  阅读全文

�?/a> 2009-03-10 16:34 发表评论

使用NTP�|�络旉��协议同步你的�|�络

Fri, 06 Mar 2009 11:48:00 GMT
NTP协议全称�|�络旉��协议�Q�Network Time Procotol�Q�。它的目的是在国际互联网上传递统一、标准的旉��。具体的实现�Ҏ��是在�|�络上指定若�q�时钟源�|�站�Q��ؓ用户提供授时服务�Q��ƈ且这些网站间应该能够�怺�比对�Q�提高准��度�?

NTP 最早是��q��国Delaware大学的Mills教授设计实现的，�?982件最初提出到现在已发展了��近20�q�_��2001�q�最新的NTPv4�_��度已�l�达��C��200毫秒。对于实际应用，又有��保�U��_�ֺ�的SNTP�Q�简单的�|�络旉��协议�Q��?

NTP是一个跨��广域网或局域网的复杂的同步旉��协议�Q�它通常可获得毫�U��的精度。RFC2030[Mills 1996]描述了SNTP�Q�Simple Network Time Protocol�Q�，目的是�ؓ了那些不需要完整NTP实现复杂性的��L��Q�它是NTP的一个子集。通常让局域网上的若干��C��机通过因特�|�与其他的NTP��L��同步旉��Q�接着再向局域网内其他客��L��提供旉��同步服务�?

NTP�?议是OSI参考模型的高层协议�Q�符合UDP传输协议格式�Q�拥有专用端�?23�?

随着旉��的推�U�，计算机的旉��会們֐�于漂�U�R�?�|�络旉��协议 (NTP) 是一�U�确保您的时钟保持准��的�Ҏ��。它��\由器、交换机、工作站和服务器之间提供了一�U�时间同步的机制。所以NTP Server�l�常应用于一些有旉��同步要求的IT�pȝ��环境中�?

一、服务端讄��

Mac OS X Server��g��默认��有了，只说一下Linux下如何设�|��?
在Ubuntu Linux中应用NTP Server非常方便�Q?
1. 安装

sudo apt-get install ntp

sudo apt-get install ntp

2. 配置
配置文�g�?etc/ntp.conf

a. 扑ֈ�server一��，��d��你喜�Ƣ的Time Server

server time.asia.apple.com  iburst dynamic

server time.asia.apple.com iburst dynamic

b. 讄��权限�Q�我的所有restrict条目如下

restrict -4 default kod notrap nomodify nopeer noquery
restrict -6 default kod notrap nomodify nopeer noquery

# Local users may interrogate the ntp server more closely.
restrict 127.0.0.1   www.5a520.cn
restrict ::1

# Clients from this (example!) subnet have unlimited access, but only if
# cryptographically authenticated.
#restrict 192.168.123.0 mask 255.255.255.0 notrust
restrict 192.168.0.0 mask 255.255.255.0

restrict -4 default kod notrap nomodify nopeer noquery restrict -6 default kod notrap nomodify nopeer noquery # Local users may interrogate the ntp server more closely. restrict 127.0.0.1 restrict ::1 # Clients from this (example!) subnet have unlimited access, but only if # cryptographically authenticated. #restrict 192.168.123.0 mask 255.255.255.0 notrust restrict 192.168.0.0 mask 255.255.255.0

3. 重启ntp服务�?/strong>
/etc/init.d/ntp restart

4. 查看服务器是否工作正�?/strong>
在服务器�q�行

Java代码

ntpq -p

ntpq -p

二、工作站同步

好了�Q�测试一下吧�Q�假设你的新服务器IP地址�?92.168.0.7。在客户端运行如下命令：
ntpdate -u 192.168.0.7

同步成功后，��会昄��如下�Q?
6 Mar 15:44:24 ntpdate[9921]: adjust time server 192.168.0.7 offset -0.007277 sec

三、交换机同步

Cisco IOS

Java代码

ciscorouter> enable
password: *********
ciscorouter# config t
ciscorouter(config)# ntp update-calendar
ciscorouter(config)# ntp server 192.168.0.4
ciscorouter(config)# ntp server 192.168.0.7
ciscorouter(config)# exit
ciscorouter# wr mem

ciscorouter> enable password: ********* ciscorouter# config t ciscorouter(config)# ntp update-calendar ciscorouter(config)# ntp server 192.168.0.4 ciscorouter(config)# ntp server 192.168.0.7 ciscorouter(config)# exit ciscorouter# wr mem

Dell 6248

Java代码

dell6248-corner>en
dell6248-corner#configure
dell6248-corner(config)#sntp server 192.168.0.7
dell6248-corner(config)#

dell6248-corner>en dell6248-corner#configure dell6248-corner(config)#sntp server 192.168.0.7 dell6248-corner(config)#

四、一些常见的旉��服务�?/strong>

210.72.145.44 ── (国家授时中心服务器IP地址)
133.100.11.8 ── 日本 ��冈大学
time-a.nist.gov 129.6.15.28 ── NIST, Gaithersburg, Maryland
time-b.nist.gov 129.6.15.29 ── NIST, Gaithersburg, Maryland
time-a.timefreq.bldrdoc.gov 132.163.4.101 ── NIST, Boulder, Colorado
time-b.timefreq.bldrdoc.gov 132.163.4.102 ── NIST, Boulder, Colorado
time-c.timefreq.bldrdoc.gov 132.163.4.103 ── NIST, Boulder, Colorado
utcnist.colorado.edu 128.138.140.44 ── University of Colorado, Boulder
time.nist.gov 192.43.244.18 ── NCAR, Boulder, Colorado
time-nw.nist.gov 131.107.1.10 ── Microsoft, Redmond, Washington
nist1.symmetricom.com 69.25.96.13 ── Symmetricom, San Jose, California
nist1-dc.glassey.com 216.200.93.8 ── Abovenet, Virginia
nist1-ny.glassey.com 208.184.49.9 ── Abovenet, New York City
nist1-sj.glassey.com 207.126.98.204 ── Abovenet, San Jose, California
nist1.aol-ca.truetime.com 207.200.81.113 ── TrueTime, AOL facility, Sunnyvale, California
nist1.aol-va.truetime.com 64.236.96.53 ── TrueTime, AOL facility, Virginia

五、��用Python脚本来获取时�?/strong>

Java代码

#!/usr/bin/python
from socket import *
import struct,os,time,sys

# Script to set Linux hardware clock (/usr/sbin/hwclock) from an NTP
# time server.   Run as "setclock.py" to simply print the time from
# the NTP server.  Run as "setclock.py --set" to set the Linux
# hardware clock (as the super user, of course).

# Based on Simon Foster's simple SNTP client from ASPN Python cookbook.
# Adapted by Paul Rubin; this script lives at:
#    http://www.nightsong.com/phr/python/setclock.py

time_server = ('time.apple.com', 123)
# time.apple.com is a stratum 2 time server.  (123 is the SNTP port number).
# More servers info can be found at
#
#   http://www.eecis.udel.edu/~mills/ntp/servers.htm
#
# Note it's considered antisocial to use a stratum 1 server (like NIST)
# for purposes like this which don't need extreme accuracy (i.e. syncing
# your own big NTP network).  See www.ntp.org for more info.
#
# You could also use time.windows.com (Microsoft server) which syncs
# all Windows XP machines everywhere, so it can presumably handle lots
# of clients.

# number of seconds between NTP epoch (1900) and Unix epoch (1970).
TIME1970 = 2208988800L      # Thanks to F.Lundh

client = socket( AF_INET, SOCK_DGRAM )
data = '\x1b' + 47 * '\0'
client.sendto(data, time_server)
data, address = client.recvfrom( 1024 )
if data:
    print 'Response received from', address,'\n'
    t = struct.unpack( '!12I', data )[10]
    if t == 0:
        raise 'invalid response'
    ct = time.ctime(t - TIME1970)
    print 'Current time = %s\n' % ct
    if len(sys.argv) > 1 and sys.argv[1] == "--set":
        os.system("/usr/sbin/hwclock --set '--date=%s'"% ct)
else:
    raise 'no data returned'

#!/usr/bin/python from socket import * import struct,os,time,sys # Script to set Linux hardware clock (/usr/sbin/hwclock) from an NTP # time server. Run as "setclock.py" to simply print the time from # the NTP server. Run as "setclock.py --set" to set the Linux # hardware clock (as the super user, of course). # Based on Simon Foster's simple SNTP client from ASPN Python cookbook. # Adapted by Paul Rubin; this script lives at: # http://www.nightsong.com/phr/python/setclock.py time_server = ('time.apple.com', 123) # time.apple.com is a stratum 2 time server. (123 is the SNTP port number). # More servers info can be found at # # http://www.eecis.udel.edu/~mills/ntp/servers.htm # # Note it's considered antisocial to use a stratum 1 server (like NIST) # for purposes like this which don't need extreme accuracy (i.e. syncing # your own big NTP network). See www.ntp.org for more info. # # You could also use time.windows.com (Microsoft server) which syncs # all Windows XP machines everywhere, so it can presumably handle lots # of clients. # number of seconds between NTP epoch (1900) and Unix epoch (1970). TIME1970 = 2208988800L # Thanks to F.Lundh client = socket( AF_INET, SOCK_DGRAM ) data = '\x1b' + 47 * '\0' client.sendto(data, time_server) data, address = client.recvfrom( 1024 ) if data: print 'Response received from', address,'\n' t = struct.unpack( '!12I', data )[10] if t == 0: raise 'invalid response' ct = time.ctime(t - TIME1970) print 'Current time = %s\n' % ct if len(sys.argv) > 1 and sys.argv[1] == "--set": os.system("/usr/sbin/hwclock --set '--date=%s'"% ct) else: raise 'no data returned'

上面�q�个脚本原址在这里，http://www.nightsong.com/phr/python/setclock.py�Q?http://www.bt285.cn�Q?http://www.guihua.org。��用方式如下：
$ python setclock.py
Response received from ('17.151.16.23', 123)

Current time = Fri Mar 6 16:03:19 2009

�?/a> 2009-03-06 19:48 发表评论

亚洲无mate20pro麻豆,亚洲AV成人片色在线观看高潮,亚洲高清中文字幕综合网

GPS�l�纬度可以用来Java解析

用Java来显�C�图片生成器

java中的io�W�记

解决 MYSQL CPU 占用 100% 的经验�ȝ��

使用org.apache.commons.net.ftp包开发FTP客户端，实现�q�度汇报�Q�实现断点箋传，中文支持

使用NTP�|�络旉���协议同步你的�|�络

　解决 MYSQL CPU 占用 100% 的经验�ȝ��

使用NTP�|�络旉��协议同步你的�|�络