基于Netty的Java数据采集软件

使用Netty进行网络通信，完成分布式的数据采集任务，可以采集500以上数据节点。

package com.xiang.dataclient;

import java.io.BufferedReader;  
import java.io.DataInputStream;  
import java.io.DataOutputStream;  
import java.io.IOException;  
import java.io.InputStreamReader;  
import java.net.Socket;  
import net.sf.json.*;
import com.xiang.redis.*;
  
public class DataClient {  
    public static final String IP_ADDR = “localhost“;
    public static final int PORT = 12345;

    public static JSONobject getJSONobject（String value1 String value2 String value3 String value4） {
		JSONobject obj = new JSONobject（）;
		obj.put（“A001“ value1）;
		obj.put（“A002“ value2）;
		obj.put（“A003“ value3）;
		obj.put（“A004“ value4）;

        return obj;
    }

    public static void main（String[] args） {
        System.out.println（“尝试连接数据采集服务器...\n“）;
        Socket socket = null;
        try {
            socket = new Socket（IP_ADDR PORT）;
            System.out.println（“服务器连接成功!“）;

            DataInputStream input = new DataInputStream（socket.getInputStream（））;
            DataOutputStream out = new DataOutputStream（socket.getOutputStream（））;
            int count = 0;

            while（true） {
                String str = “1 2 3 4“;
                String[] strs = str.split（“ “）;
                if （strs.length >= 4）
                    str = getJSONobject（strs[0] strs[1] strs[2] strs[3]）.toString（）;

                out.writeUTF（“第“ + count++ +“条数据:“ + str）;

                String ret = input.readUTF（）;
                System.out.println（ret）;

                Thread.sleep（5000）;
            }

            //out.close（）;
            //input.close（）;
        } catch （Exception e） {
            System.out.println（“服务器连接异常!:“ + e.getMessage（））;
        } finally {

            if （socket != null） {
                try {
                    socket.close（）;
                } catch （IOException e） {
                    socket = null;
                    System.out.println（“socket断开异常:“ + e.getMessage（））;
                }
            }
        }
    }    
}    

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2017-11-26 21:29  DataClient\
     文件         456  2017-09-13 23:20  DataClient\.classpath
     目录           0  2017-11-28 09:19  DataClient\.idea\
     文件          10  2017-11-26 21:29  DataClient\.idea\.name
     文件         808  2017-11-28 09:32  DataClient\.idea\compiler.xml
     目录           0  2017-11-26 21:29  DataClient\.idea\copyright\
     文件          76  2017-11-26 21:29  DataClient\.idea\copyright\profiles_settings.xml
     文件         256  2017-11-30 23:32  DataClient\.idea\encodings.xml
     文件         877  2017-11-28 09:51  DataClient\.idea\misc.xml
     文件         260  2017-11-26 21:29  DataClient\.idea\modules.xml
     文件         164  2017-11-26 21:29  DataClient\.idea\vcs.xml
     文件       38616  2017-12-03 23:07  DataClient\.idea\workspace.xml
     文件         386  2017-09-13 22:42  DataClient\.project
     目录           0  2017-09-13 22:42  DataClient\.settings\
     文件         670  2017-09-13 22:57  DataClient\.settings\org.eclipse.jdt.core.prefs
     文件        2570  2017-11-28 09:00  DataClient\DataClient.iml
     目录           0  2017-12-03 22:27  DataClient\bin\
     目录           0  2017-12-03 22:27  DataClient\bin\com\
     目录           0  2017-12-03 22:27  DataClient\bin\com\xiang\
     目录           0  2017-12-03 22:27  DataClient\bin\com\xiang\dataclient\
     文件        2986  2017-12-03 22:27  DataClient\bin\com\xiang\dataclient\DataClient.class
     目录           0  2017-09-13 22:43  DataClient\src\
     目录           0  2017-09-13 22:43  DataClient\src\com\
     目录           0  2017-09-13 22:43  DataClient\src\com\xiang\
     目录           0  2017-12-03 22:24  DataClient\src\com\xiang\dataclient\
     文件        2077  2017-12-03 22:24  DataClient\src\com\xiang\dataclient\DataClient.java
     目录           0  2017-11-28 09:02  DataServer\
     文件         373  2017-09-13 23:17  DataServer\.classpath
     目录           0  2017-11-28 09:18  DataServer\.idea\
     文件          10  2017-11-28 09:02  DataServer\.idea\.name
     文件         686  2017-11-28 09:01  DataServer\.idea\compiler.xml
............此处省略57个文件信息