Code d'implémentation de l'écoute du port Java

Cet article vous apporte le code d'implémentation de la surveillance des ports Java. Il a une certaine valeur de référence. Les amis dans le besoin peuvent s'y référer.

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;
public class test {
	public static void main(String[] args) throws IOException, ClassNotFoundException, SQLException {
		// 客户端

		SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHHmmss");
		try {
			PrintStream out = new PrintStream("D://Systemout" + format.format(new Date()) + ".txt");
			System.setOut(out);
		} catch (FileNotFoundException e) {
			e.printStackTrace();
		}
		// System.out.println("aaa");
		// 1、创建客户端Socket，指定服务器地址和端口
		ServerSocket serverSocket = new ServerSocket(7080);
		while(true){	
		Socket socket = serverSocket.accept();
		// 2、获取输出流，向服务器端发送信息
		/*
		 * Scanner scanner =new Scanner(socket.getInputStream());//创建一个客户端的输入流
		 * （用于在服务端显示）
		 * 
		 * String msg; while(scanner.hasNextLine()){//获取客户端发送的信息 msg=scanner.nextLine();
		 * System.out.println(msg); }
		 */
		BufferedInputStream bis = new BufferedInputStream(socket.getInputStream());
		DataInputStream dis = new DataInputStream(bis);
		byte[] bytes = new byte[1]; // 一次读取一个byte
		String ret = "";
		while (dis.read(bytes) != -1) {
			ret += bytesToHexString(bytes) + " ";
			if (dis.available() == 0) { // 一个请求
				System.out.print(ret + ' ');
			}
		}
	//	String ret = "47 38 30 31 33 35 36 32 fe 0d ff 06 6e ff 53 51 55 65 78 67 19 21 14 c7 cb fe 0c 01 07 e2 09 06 10 01 04 01 2f 01 0a 27 10 00 3c 1c 59 15 1d";
		System.out.println("---");
		String ret1 = ret.substring(0, ret.length());
		System.out.println("有效字符串为:" + ret1);
		String ret2 = ret1.substring(0, 24);
		System.out.println("注册码:" + ret2);
		String ret3 = ret1.substring(24, 75);
		System.out.println("设备码:" + ret3);
		String ret4 = ret1.substring(75, ret1.length());
		System.out.println("数据:" + ret4);

		String zcm = ret2.substring(0, ret2.length()).replaceAll(" ", "");

		String ss1 = ret4.substring(9, 30).replaceAll(" ", "");
		String ss2 = ret4.substring(30, 54).replaceAll(" ", "");
		String ss3 = ret4.substring(54, 60).replaceAll(" ", "");
		String ss4 = ret4.substring(60, 65).replaceAll(" ", "");

		int year = Integer.parseInt(ss1.substring(0, 4).replaceAll("^0[x|X]", ""), 16);
		System.out.println("年份:" + year);

		int month = Integer.parseInt(ss1.substring(4, 6).replaceAll("^0[x|X]", ""), 16);
		System.out.println("月:" + month);

		int day = Integer.parseInt(ss1.substring(6, 8).replaceAll("^0[x|X]", ""), 16);
		System.out.println("日:" + day);

		int hour = Integer.parseInt(ss1.substring(8, 10).replaceAll("^0[x|X]", ""), 16);
		System.out.println("时:" + hour);

		int min = Integer.parseInt(ss1.substring(10, 12).replaceAll("^0[x|X]", ""), 16);
		System.out.println("分:" + min);

		int sec = Integer.parseInt(ss1.substring(12, 14).replaceAll("^0[x|X]", ""), 16);
		System.out.println("秒:" + sec);

		int temp = Integer.parseInt(ss2.substring(0, 4).replaceAll("^0[x|X]", ""), 16);
		System.out.println("温度:" + temp);

		int sw = Integer.parseInt(ss2.substring(4, 8).replaceAll("^0[x|X]", ""), 16);
		System.out.println("水位:" + sw);

		// 字符串类型的日期与时间直接存储到数据库
		String date = String.valueOf(year) + "-" + String.valueOf(month) + "-" + String.valueOf(day);
		System.out.println(date);
		String time = String.valueOf(hour) + "时" + String.valueOf(min) + "分" + String.valueOf(sec) + "秒";
		System.out.println(time);

		String driverName = "com.mysql.jdbc.Driver";
		String dbURL = "jdbc:mysql://localhost:3306/dire";
		String userName = "root";
		String userPwd = "sa";

		Class.forName(driverName);
		Connection con = DriverManager.getConnection(dbURL, userName, userPwd);
		System.out.println("连接数据库成功");
		Statement stat = con.createStatement();
		String sql = "INSERT INTO shuju(注册码,日期,时间,温度,水位) VALUES(?,?,?,?,?)";

		PreparedStatement pstmt;
		try {
			pstmt = (PreparedStatement) con.prepareStatement(sql);
			pstmt.setObject(1, zcm);
			pstmt.setObject(2, date);
			pstmt.setObject(3, time);
			pstmt.setObject(4, temp);
			pstmt.setObject(5, sw);
			pstmt.executeUpdate();
			pstmt.close();
			con.close();
		} catch (SQLException e) {

			e.printStackTrace();

		}

		System.out.println("成功");
	}
	}
	public static String bytesToHexString(byte[] src) {
		StringBuilder stringBuilder = new StringBuilder("");
		if (src == null || src.length <= 0) {
			return null;
		}
		for (int i = 0; i < src.length; i++) {
			int v = src[i] & 0xFF;
			String hv = Integer.toHexString(v);
			if (hv.length() < 2) {
				stringBuilder.append(0);
			}
			stringBuilder.append(hv);
		}
		return stringBuilder.toString();
	}

}

Recommandations associées :

Résumé de l'expérience de surveillance dynamique/surveillance statique des ports par défaut et non par défaut

Que diriez-vous de résoudre le problème selon lequel lorsque le socket écoute sur le port, un seul client peut envoyer des données au port

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!