smart-farming/huimv-smart-management/src/main/java/com/huimv/management/socket/Server.java

package com.huimv.management.socket;



import com.huimv.management.socket.eartagrecive.service.IClientDataPacketService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

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

@Component
public class Server implements CommandLineRunner {

    @Autowired
    private IClientDataPacketService iClientDataPacketService;

    @Override
    public void run(String... args) throws Exception {
        try {

            // 初始化服务端socket连接， 并监听8888端口的socket请求
            ServerSocket serverSocket = new ServerSocket(8888);

            System.out.println("****** I am Server, now begin to wait the client ******");

            int count = 0;

            // 处理socket请求
            Socket socket = null;
            while (true) {
                socket = serverSocket.accept();
                ServerThread serverThread = new ServerThread(socket, iClientDataPacketService);
                System.out.println("client host address is: " + socket.getInetAddress().getHostAddress());
                serverThread.start();
                count++;
                System.out.println("now client count is: " + count);

            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}