자바 소켓을 이용한 클라이언트

자바로 소켓(모드버스 프로토콜)을 이용한 클라이언트 단을 테스트로 만들어 봤습니다.

딱 클라이언트의 기본 역할만 한 것이기 때문에 활용하셔서 응용하시면 될 것 같아요

주고받는 데이터는 바이트로 주고받기 때문에 일부로 바이트 배열을 사용하여 진행하였습니다.

저도 계속 수정하고 보완하려구요.

후에는 서버쪽 만들어 보도록 하겠습니다.

 

 

 

 

import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
 
class Client {
 
    // SendData
    byte[] SData = new byte[12];
    byte[] RData = new byte[15];
    int read;
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    byte[] buffer = new byte[15];
    Boolean Client = false;
    
 
    /**************************************************************
     * 소켓 연결 메소드 
     * SendData() 메소드 사용
     * 
     * @return
     *************************************************************/
    public int InClient() {
        int iret = 1;
        
        String serverIP = "127.0.0.1";
        try {
            Socket socket = new Socket(serverIP, 502);
            System.out.println("소켓 연결 완료");
            if (socket != null) {
                Client = true;
            }
 
            while (Client) {
 
                OutputStream os = socket.getOutputStream();
                DataOutputStream dos = new DataOutputStream(os);
                SendData();
                dos.write(SData);
                dos.flush();
 
                InputStream in = socket.getInputStream();
                DataInputStream dis = new DataInputStream(in);
 
                read = dis.read(RData, 0, RData.length);
                ReceiveData(read, socket);
                
            
            }
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
        return iret;
    }
 
    /**
     * ****************************************************************** 
     * 보내는 데이터 설정
     * 모드버스 프로토콜 사용
     *******************************************************************/
    public void SendData() {
        try {
            byte[] SendData = new byte[12];
 
            SendData[0] = (byte) 0x00;
            SendData[1] = (byte) 0x00;
            SendData[2] = (byte) 0x00;
            SendData[3] = (byte) 0x00;
            SendData[4] = (byte) 0x00;
            SendData[5] = (byte) 0x06;
            SendData[6] = (byte) 0x01;
            SendData[7] = (byte) 0x03;
            SendData[8] = (byte) 0x00;
            SendData[9] = (byte) 0x00;
            SendData[10] = (byte) 0x00;
            SendData[11] = (byte) 0x19;
 
            System.arraycopy(SendData, 0, SData, 0, SendData.length);
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
 
    }
 /** ***************************************
  * 데이터 받는 메소드
  * 
  */
    public void ReceiveData(int read, Socket socket) {
        try {
            System.out.println(read);
            if (read > 0) {
                
                System.arraycopy(RData, 0, buffer, 0, read  );
                baos.write(buffer, 0, buffer.length);
                baos.flush();
            }
            byte[] data = baos.toByteArray();
            System.out.println(data.length);
            
            
             for(int i = 0; i< data.length; i++) {
             
             System.out.println(data[i]);
             
             }
                     
        } catch (Exception e) {
            System.out.println(e.getMessage());
 
        }
 
    }
}
 
class Ex1 {
    public static void main(String[] args) 
    {
        Client c = new Client();
        c.InClient();    
    }
 
}