JAVA------5.启动服务端，客户端发送数据，用户端接收数据，string数组转byte字节，CrcUtil校验

服务端启动

public class ServerDemo {
    //crc 校验
    private static CrcUtil demo;
    //str 转字节
    private static StringToByteutil strToByte;
    private static  Connection conn = null;
    private SimpleDateFormat formatter = new SimpleDateFormat(
            "yyyy-MM-dd HH:mm:ss");
    static String driver = "com.mysql.jdbc.Driver";
    // URL指向要访问的数据库名******
    //static String url = "jdbc:mysql://123.57.89.35:3306/hhxficdz_schema";
    static String url = "jdbc:mysql://localhost:3306/hhxficdz_schema";
    // MySQL配置时的用户名
    static String user = "root";
    // Java连接MySQL配置时的密码******
    //static String password = "icdz123";
    static String password = "123456";
    //crc校验
    private static CrcUtil crc;
    private static  Connection getconn() {
        //驱动程序名//不固定，根据驱动
        try {
            Class.forName(driver);
            conn = DriverManager.getConnection(url, user, password);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        // System.out.println(props.getProperty("mysql.connection.driver_class"));
        return conn;
    }
    /**
     * 4800服务端口 线程2秒接受 ：
     * 接受一段指令
     * ---》查询数据库
     * -----》修改数据库
     * -------》返回指令
     * @param args
     * @throws IOException
     */


    public static void main(String args[]) throws IOException {  

        //为了简单起见，所有的异常信息都往外抛  
        int port = 4800;  
        //定义一个ServerSocket监听在端口8899上  
        ServerSocket server = new ServerSocket(port);  
        while (true) {  
            //server尝试接收其他Socket的连接请求，server的accept方法是阻塞式的  
            Socket socket = server.accept();  
            //每接收到一个Socket就建立一个新的线程来处理它  
            new Thread(new Task(socket)).start();  
        }  

    } 

    /** 
     * 用来处理Socket请求的 
     */  
    static class Task implements Runnable {  

        private Socket socket;  

        public Task(Socket socket) {  
            this.socket = socket;  
        }  

        public void run() {  
            try {  
                handleSocket();  
            } catch (Exception e) {  
                e.printStackTrace();  
            }  
        }  

        /** 
         * 跟客户端Socket进行通信 
         * @throws Exception 
         */  
        public void handleSocket() throws Exception {  
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
            StringBuilder sb = new StringBuilder();  
            String temp;  
            int index;  
            int flag=1;
            while ((temp=br.readLine()) != null) {  
                System.out.println(temp);  
                if ((index = temp.indexOf("eof")) != -1) {//遇到eof时就结束接收  
                    sb.append(temp.substring(0, index));  
                    break;  
                }  
                sb.append(temp);  
            }  
            System.out.println("from client: " + sb);  

客户端发送指令

public class ClientDemo {  
      
    
    
    
    
       public static void main(String args[]) throws Exception {  
          //为了简单起见，所有的异常都直接往外抛  
         String host = "127.0.0.1";  //要连接的服务端IP地址  
         int port = 4800;   //要连接的服务端对应的监听端口  
         //与服务端建立连接  
         Socket client = new Socket(host, port);  
          //建立连接后就可以往服务端写数据了  
         Writer writer = new OutputStreamWriter(client.getOutputStream());  
          writer.write("FF01037400014AA856");  
          writer.write("eof
");  
          writer.flush();  
          //写完以后进行读操作  
         BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream()));  
          StringBuffer sb = new StringBuffer();  
          String temp;  
          int index;  
          while ((temp=br.readLine()) != null) {  
             if ((index = temp.indexOf("eof")) != -1) {  
                sb.append(temp.substring(0, index));  
                break;  
             }  
             sb.append(temp);  
          }  
          System.out.println("from server: " + sb);  
          writer.close();  
          br.close();  
          client.close();  
       }  
    }  

string数组转byte字节

public class CrcTest {
    private static CrcUtil demo;
    /**
     * @param args
     */
    public static void main(String[] args) {
        String testStr = "FF060374000101";
        
        String str = "FF060374000101";//字符串
        int m=str.length()/2;
        if(m*2<str.length()){
        m++;
        }
        String[] strs=new String[m];
        int j=0;
        for(int i=0;i<str.length();i++){
        if(i%2==0){//每隔两个
        strs[j]=""+str.charAt(i);
        }else{
        strs[j]="0x"+strs[j]+str.charAt(i);//将字符加上两个空格
        j++;
        }           
        }
        
        //
        byte b2[]=new byte[7];
        for (int i = 0; i < 7; i++) {
            b2[i]=(byte) Integer.parseInt(strs[i].substring(2),16);
        }
        
        System.out.println(Arrays.toString(strs));
        System.out.println(String.valueOf(Integer.toHexString(demo.CRC16(b2,7))).toUpperCase());
        
        
        // 可以用 StringBuilder 这个类，里面有一个接口replace，如下
        StringBuilder sb = new StringBuilder("abcd");
        sb.replace(1, 2, "测试是否替换指定的第二个元素");
        System.out.println(sb.toString());
        
        //String 替换指定位置的字符
        String s="02";
        s=s.replaceFirst(""+s.charAt(1),"7") ;
        System.out.println(s);
    }

}

/**
 * 
 * string 转 字节
 *FF060374000101
 *[0xFF, 0x06, 0x03, 0x74, 0x00, 0x01, 0x01]
 */
public class StringToByteutil {
    
    private static CrcUtil demo;
    //静态方法
    static  byte[] stringToByte(String leftstr) {
        // TODO Auto-generated method stub
        int m=leftstr.length()/2;
        if(m*2<leftstr.length()){
        m++;
        }
        String[] strs=new String[m];
        int j=0;
        for(int i=0;i<leftstr.length();i++){
        if(i%2==0){//每隔两个
        strs[j]=""+leftstr.charAt(i);
        }else{
        strs[j]="0x"+strs[j]+leftstr.charAt(i);//将字符加上两个空格
        j++;
        }           
        }
        byte b2[]=new byte[m];
        for (int i = 0; i < m; i++) {
            b2[i]=(byte) Integer.parseInt(strs[i].substring(2),16);
        }
        
        return b2;
    }
    
    public static void main(String[] args) {
        //字节数组转换校验码
        System.out.println(String.valueOf(Integer.toHexString(demo.CRC16(stringToByte("FF060374000101"),7))).toUpperCase());
    }
}

crc校验

public class CrcUtil {


    public static void main(String[] args) throws IOException {
        String testStr = "FF060374000101";
        byte b1[]={(byte) 0xff,0x06,0x03,0x74,0x00,0x01,0x01};
        System.out.println(Integer.toHexString(CRC16(b1,7)));
    }


    static  byte[]  auchCRCHi = new byte[]{
        (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x01, (byte)0xC0, 
        (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, 
        (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, 
        (byte)0x80, (byte)0x41, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, 
        (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, 
        (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, 
        (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, 
        (byte)0x81, (byte)0x40, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, 
        (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x01, (byte)0xC0, 
        (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, 
        (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, 
        (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, 
        (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x01, (byte)0xC0, 
        (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, 
        (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, 
        (byte)0x80, (byte)0x41, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, 
        (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x01, (byte)0xC0, 
        (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, 
        (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, 
        (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, 
        (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, 
        (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, 
        (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, 
        (byte)0x81, (byte)0x40, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, 
        (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40, (byte)0x01, (byte)0xC0, (byte)0x80, (byte)0x41, (byte)0x01, (byte)0xC0, 
        (byte)0x80, (byte)0x41, (byte)0x00, (byte)0xC1, (byte)0x81, (byte)0x40
    };

    static byte[]  auchCRCLo = new byte[]{
        (byte)0x00, (byte)0xC0, (byte)0xC1, (byte)0x01, (byte)0xC3, (byte)0x03, (byte)0x02, (byte)0xC2, (byte)0xC6, (byte)0x06, 
        (byte)0x07, (byte)0xC7, (byte)0x05, (byte)0xC5, (byte)0xC4, (byte)0x04, (byte)0xCC, (byte)0x0C, (byte)0x0D, (byte)0xCD, 
        (byte)0x0F, (byte)0xCF, (byte)0xCE, (byte)0x0E, (byte)0x0A, (byte)0xCA, (byte)0xCB, (byte)0x0B, (byte)0xC9, (byte)0x09, 
        (byte)0x08, (byte)0xC8, (byte)0xD8, (byte)0x18, (byte)0x19, (byte)0xD9, (byte)0x1B, (byte)0xDB, (byte)0xDA, (byte)0x1A, 
        (byte)0x1E, (byte)0xDE, (byte)0xDF, (byte)0x1F, (byte)0xDD, (byte)0x1D, (byte)0x1C, (byte)0xDC, (byte)0x14, (byte)0xD4, 
        (byte)0xD5, (byte)0x15, (byte)0xD7, (byte)0x17, (byte)0x16, (byte)0xD6, (byte)0xD2, (byte)0x12, (byte)0x13, (byte)0xD3, 
        (byte)0x11, (byte)0xD1, (byte)0xD0, (byte)0x10, (byte)0xF0, (byte)0x30, (byte)0x31, (byte)0xF1, (byte)0x33, (byte)0xF3, 
        (byte)0xF2, (byte)0x32, (byte)0x36, (byte)0xF6, (byte)0xF7, (byte)0x37, (byte)0xF5, (byte)0x35, (byte)0x34, (byte)0xF4, 
        (byte)0x3C, (byte)0xFC, (byte)0xFD, (byte)0x3D, (byte)0xFF, (byte)0x3F, (byte)0x3E, (byte)0xFE, (byte)0xFA, (byte)0x3A, 
        (byte)0x3B, (byte)0xFB, (byte)0x39, (byte)0xF9, (byte)0xF8, (byte)0x38, (byte)0x28, (byte)0xE8, (byte)0xE9, (byte)0x29, 
        (byte)0xEB, (byte)0x2B, (byte)0x2A, (byte)0xEA, (byte)0xEE, (byte)0x2E, (byte)0x2F, (byte)0xEF, (byte)0x2D, (byte)0xED, 
        (byte)0xEC, (byte)0x2C, (byte)0xE4, (byte)0x24, (byte)0x25, (byte)0xE5, (byte)0x27, (byte)0xE7, (byte)0xE6, (byte)0x26, 
        (byte)0x22, (byte)0xE2, (byte)0xE3, (byte)0x23, (byte)0xE1, (byte)0x21, (byte)0x20, (byte)0xE0, (byte)0xA0, (byte)0x60, 
        (byte)0x61, (byte)0xA1, (byte)0x63, (byte)0xA3, (byte)0xA2, (byte)0x62, (byte)0x66, (byte)0xA6, (byte)0xA7, (byte)0x67, 
        (byte)0xA5, (byte)0x65, (byte)0x64, (byte)0xA4, (byte)0x6C, (byte)0xAC, (byte)0xAD, (byte)0x6D, (byte)0xAF, (byte)0x6F, 
        (byte)0x6E, (byte)0xAE, (byte)0xAA, (byte)0x6A, (byte)0x6B, (byte)0xAB, (byte)0x69, (byte)0xA9, (byte)0xA8, (byte)0x68, 
        (byte)0x78, (byte)0xB8, (byte)0xB9, (byte)0x79, (byte)0xBB, (byte)0x7B, (byte)0x7A, (byte)0xBA, (byte)0xBE, (byte)0x7E, 
        (byte)0x7F, (byte)0xBF, (byte)0x7D, (byte)0xBD, (byte)0xBC, (byte)0x7C, (byte)0xB4, (byte)0x74, (byte)0x75, (byte)0xB5, 
        (byte)0x77, (byte)0xB7, (byte)0xB6, (byte)0x76, (byte)0x72, (byte)0xB2, (byte)0xB3, (byte)0x73, (byte)0xB1, (byte)0x71, 
        (byte)0x70, (byte)0xB0, (byte)0x50, (byte)0x90, (byte)0x91, (byte)0x51, (byte)0x93, (byte)0x53, (byte)0x52, (byte)0x92, 
        (byte)0x96, (byte)0x56, (byte)0x57, (byte)0x97, (byte)0x55, (byte)0x95, (byte)0x94, (byte)0x54, (byte)0x9C, (byte)0x5C, 
        (byte)0x5D, (byte)0x9D, (byte)0x5F, (byte)0x9F, (byte)0x9E, (byte)0x5E, (byte)0x5A, (byte)0x9A, (byte)0x9B, (byte)0x5B, 
        (byte)0x99, (byte)0x59, (byte)0x58, (byte)0x98, (byte)0x88, (byte)0x48, (byte)0x49, (byte)0x89, (byte)0x4B, (byte)0x8B, 
        (byte)0x8A, (byte)0x4A, (byte)0x4E, (byte)0x8E, (byte)0x8F, (byte)0x4F, (byte)0x8D, (byte)0x4D, (byte)0x4C, (byte)0x8C, 
        (byte)0x44, (byte)0x84, (byte)0x85, (byte)0x45, (byte)0x87, (byte)0x47, (byte)0x46, (byte)0x86, (byte)0x82, (byte)0x42, 
        (byte)0x43, (byte)0x83, (byte)0x41, (byte)0x81, (byte)0x80, (byte)0x40
    };
    Socket socket = null;


    static int CRC16(byte[] puchMsg, int len)
    {
        int ucCRCHi = (byte)0xFF ; /* ??CRC×??ú3?ê??ˉ */
        int ucCRCLo = (byte)0xFF ; /* μíCRC ×??ú3?ê??ˉ */
        int iIndex ; /* CRC?-?·?Dμ??÷òy */                                                                                                                                                                                                                                         /* ′?ê????￠?o3??? */
        for (int i = 0; i < len; ++i) {  
            iIndex = (ucCRCLo ^ puchMsg[i]) & 0x00ff;  
            ucCRCLo = ucCRCHi ^ auchCRCHi[iIndex];  
            ucCRCHi = auchCRCLo[iIndex];  
        }  
        return ((ucCRCHi & 0x00ff) << 8) | (ucCRCLo & 0x00ff) & 0xffff;  
    }  









    private short CRCCheck(byte[] dat,int num )
    {
        short CRCSum=0;

        return CRCSum;
    }

    /**
     * 读取数据
     * 
     * @param in
     * @return
     */
    public String doRead(InputStream in) {
        // 引用关系，不要在此处关闭流
        String aa = "";
        try {
            byte[] bytes = new byte[in.available()];
            in.read(bytes);
            aa = new String(bytes).trim();
        } catch (IOException e) {
            e.printStackTrace();
        }

        return aa;
    }

    /**
     * 写入数据
     * 
     * @param out
     * @return
     */
    public boolean doWrite(OutputStream out, String resStr) {
        // 引用关系，不要在此处关闭流
        try {
            out.write(resStr.getBytes());
            out.flush();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return true;
    }
    /**
     * byte数组转int
     * @param src
     * @param offset
     * @return
     */
    public static int bytesToInt(byte[] b) {  
        int mask=0xff;
        int temp=0;
        int n=0;
        for(int i=0;i<b.length;i++){
            n<<=8;
            temp=b[i]&mask;
            n|=temp;
        }
        return n;  
    }  
    /**
     * int转byte数组
     * @param value
     * @return
     */
    public static byte[] intToBytes(int value)   
    {   
        byte[] byte_src = new byte[4];  
        byte_src[3] = (byte) ((value & 0xFF000000)>>24);  
        byte_src[2] = (byte) ((value & 0x00FF0000)>>16);  
        byte_src[1] = (byte) ((value & 0x0000FF00)>>8);    
        byte_src[0] = (byte) ((value & 0x000000FF));          
        return byte_src;  
    }  
    /**
     * double转byte数组
     * @param d
     * @return
     */
    public static byte[] doubleToBytes(double d)  
    {  
        byte writeBuffer[]= new byte[4];  
        long v = Double.doubleToLongBits(d);    
        writeBuffer[0] = (byte)(v >>> 24);  
        writeBuffer[1] = (byte)(v >>> 16);  
        writeBuffer[2] = (byte)(v >>>  8);  
        writeBuffer[3] = (byte)(v >>>  0);  
        return writeBuffer; }

    /**
     * byte数组转double
     * @param readBuffer
     * @return
     */
    public static double bytesToDouble(byte[] b) {
        long l;
        l = b[0];
        l &= 0xff;
        l |= ((long) b[1] << 8);
        l &= 0xffff;
        l |= ((long) b[2] << 16);
        l &= 0xffffff;
        l |= ((long) b[3] << 24);
        l &= 0xffffffffl;
        return Double.longBitsToDouble(l);  
    }

    /**
     * byte数组转float
     * @param b
     * @param index
     * @return
     */
    public static float getFloat(byte[] b) {
        int l;
        l = b[3];
        l &= 0xff;
        l |= ((long) b[2] << 8);
        l &= 0xffff;
        l |= ((long) b[1] << 16);
        l &= 0xffffff;
        l |= ((long) b[0] << 24);
        return Float.intBitsToFloat(l);
    }
    /**
     * float转byte数组
     * @param p
     * @return
     */
    private byte[] GetBytes(float p) {
        byte[] data = new byte[4];  
        int ivalue = Float.floatToIntBits(p);  

        data[0] = (byte)(ivalue >> 24);  
        data[1] = (byte)(ivalue >> 16);  
        data[2] = (byte)(ivalue >>  8);  
        data[3] = (byte) ivalue;  
        return data;  // TODO Auto-generated method stub
    }



}