Java的多线程+Socket

客户端:

package com.wulala;

import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {
    public static void main(String[] args) {
        Client client = new Client();
        client.run();

    }

    public void run() {
        Socket client;
        try {
            client = new Socket("127.0.0.1", 9999);
            // 2.打开socket的流信息，准备下面的操作
            OutputStream os = client.getOutputStream();
            // 3.写信息
            os.write(("xxxxasdf12233").getBytes());

           }
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

括号可能不完整, 不重要.

客户端没啥可说的, 就是打开一个目标服务器一个IP, 跟端口, 然后outputsteam一些东西进去, 模拟回头STM32通过GPRS连接服务器后通过串口透传发送数据.

服务器端:

package com.wulala;

import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class MultiSocketServer {
    public static void main(String args[]) {
        MultiSocketServer multiSocketServer = new MultiSocketServer();
        try {
            multiSocketServer.startServer();
        } catch (Exception ex) {

            System.out.println(ex.getMessage());
        }

    }

    public void startServer() throws IOException {
        ServerSocket ss = null;
        try {
            ss = new ServerSocket(9999);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        while (true) {
            // 1.打开socket连接
            // 等待客户端的请求
            final Socket server = ss.accept();

            System.out.println("服务-----------请求开始start");

            // 2.打开socket的流信息，准备下面的操作
            final InputStream is = server.getInputStream();
            byte b[] = new byte[1024];

            int readCount = is.read(b);

            String str = new String(b);

            str = str.trim();

            final String serverFileName = str;

            if (readCount > 0) {
                new Thread() {

                    @Override
                    public void run() {

                        System.out.println("线程" + Thread.currentThread().getName() + "启动");
                        // 3.对流信息进行读写操作
                        System.out.println("客户端传过来的信息是：" + serverFileName);

                        ExecuteDML edml = new ExecuteDML();
                        try {
                            edml.initParam("dbconfig.properties");
                        } catch (Exception e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                        int insertResult = 0;
                        
                        String deviceID = "";
                        int activate = 0;
                        if (serverFileName.length() > 9) {
                            deviceID = serverFileName.substring(0, 8);
                            activate = Integer.valueOf(serverFileName.substring(8));
                        }
                        try {
                            //insertResult = edml.insertWXData("aaaa", 113);
                            insertResult = edml.insertWXData(deviceID, activate);
                            System.out.println("Total "+insertResult+" result been changed");
                        } catch (Exception e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                        try {
                            is.close();
                            server.close();
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }

                        return;
                    }
                }.start();
            }

            System.out.println("服务-----------请求结束over");
        }
    }
}

简单来说, 一有数据过来, 就起一个线程, 在这个项目里面, 通常发一个字符串过来就完事, 判断字符串的前8位为设备名, 后面就是激活数.或者别的什么.

以后要进行接收数据的校验, 分析什么的, 迟点重构吧.

还有一个写数据库的类:

package com.wulala;

import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.util.Properties;
import java.util.UUID;

public class ExecuteDML {
    private String driver;
    private String url;
    private String user;
    private String password;

    public void initParam(String paramFile) throws Exception {
        Properties props = new Properties();
        props.load(new FileInputStream(paramFile));
        driver = props.getProperty("driverClassName");
        url = props.getProperty("url");
        user = props.getProperty("user");
        password = props.getProperty("password");

    }

    public int insertData(String data) throws Exception {
        Class.forName(driver);
        try (Connection conn = DriverManager.getConnection(url, user, password); Statement stmt = conn.createStatement()) {
            return stmt.executeUpdate("INSERT INTO MEMS_REC (ID,X,Y, CREATE_TIME) VALUES ('" + UUID.randomUUID().toString() + "','1','" + data
                    + "', now());");
        }
    }

    public int insertWXData(String deviceID,int activate) throws Exception {
        Class.forName(driver);
        try (Connection conn = DriverManager.getConnection(url, user, password); Statement stmt = conn.createStatement()) {
            return stmt.executeUpdate("INSERT INTO WANG_XIN (ID,DEVICE_ID,ACTIVATE) VALUES ('" + UUID.randomUUID().toString() + "','"+deviceID+"'," + activate
                    + ");");
        }
    }
    // public static void main(String[] args) throws Exception {
    //
    // ExecuteDML edml = new ExecuteDML();
    // edml.initParam("dbconfig.properties");
    // int result = edml.insertData("3");
    // System.out.println("Total " + result + " record been add");
    // }

}