반응형
JAVA에서 소켓통신을 위한 예제입니다.
단순 문자열처리, VO객체 정보를 직렬화하여 처리하기, JSON형태로 데이터 주고 받기 3가지 방식에 대해 알아볼 예정이며 이번 포스팅에서는 단순 메시지를 주고 받는 예제를 진행하겠습니다.
Socket Server
SocketThreadServer.java
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import org.apache.log4j.Logger;
public class SocketThreadServer extends Thread {
private static final Logger logger = Logger.getLogger(SocketThreadServer.class);
private Socket socket;
public SocketThreadServer(Socket socket){
this.socket=socket;
}
//단순 문자열 Thread server
public void run(){
BufferedReader br = null;
PrintWriter pw = null;
try{
String connIp = socket.getInetAddress().getHostAddress();
System.out.println(connIp + "에서 연결 시도.");
/*
* 접근한 소켓 계정의 ip를 체크한다. KTOA 연동 모듈인지 체크
* 정상이면 먼저 정상 접근되었음을 알린다.
**/
br = new BufferedReader(
new InputStreamReader(socket.getInputStream()));
pw = new PrintWriter(socket.getOutputStream());
// 클라이언트에서 보낸 문자열 출력
System.out.println(br.readLine());
// 클라이언트에 문자열 전송
pw.println("수신되었다. 오버");
pw.flush();
}catch(IOException e){
logger.error(e);
}finally{
try{
if(pw != null) { pw.close();}
if(br != null) { br.close();}
if(socket != null){socket.close();}
}catch(IOException e){
logger.error(e);
}
}
}
}
App.java - main()
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import org.apache.log4j.Logger;
import com.psw.socket.SocketThreadServer;
public class App {
private static final Logger logger = Logger.getLogger(App.class);
private static final int PORT_NUMBER = 4432;
public static void main(String[] args) throws IOException{
logger.info("::: :::");
logger.info("::: Socket Application Process Start :::");
logger.info("::: :::");
try(ServerSocket server = new ServerSocket(PORT_NUMBER)){
while(true){
Socket connection = server.accept();
Thread task = new SocketThreadServer(connection);
task.start();
}
}catch(IOException e){
logger.error(e);
}
}
}
Socket Client
Client1.java
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
public class Client1 {
private Socket socket;
private BufferedReader br;
private PrintWriter pw;
public Client1(String ip, int port) {
try {
// 서버에 요청 보내기
socket = new Socket(ip, port);
System.out.println(socket.getInetAddress().getHostAddress() + "에 연결됨");
// 메시지 받기
br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
pw = new PrintWriter(socket.getOutputStream());
// 메세지 전달
pw.println("메시지를 발송한다. 오버!");
pw.flush();
// 응답 출력
System.out.println(br.readLine());
} catch (IOException e) {
System.out.println(e.getMessage());
} finally {
// 소켓 닫기 (연결 끊기)
try {
if(socket != null) { socket.close(); }
if(br != null) { br.close(); }
if(pw != null) { pw.close(); }
} catch (IOException e) {
System.out.println(e.getMessage());
}
}
}
}
App.java
public class App{
public static void main( String[] args ) {
String ip = "연결할 주소(ip)";
int port = 4432;
new Client1(ip, port);
}
}
실행 결과
1. 서버를 먼저 실행합니다.
2. 소켓서버가 열리면 클라이언트에서 연결정보로 연결 후 메시지를 발송합니다.
3. 서버에서는 클라이언트가 발송한 문자열을 출력하고 전달할 문자열을 발신합니다.
반응형
'JAVA' 카테고리의 다른 글
| JAVA - Sokcet 통신(JSON 형태로 vo객체 넘기고 받기, simple json, gson) (2) | 2020.05.28 |
|---|---|
| JAVA - Sokcet 통신(VO 데이터 직렬화하여 넘기기, ObjectInputStream, ObjectOutputStream) (0) | 2020.05.28 |
| JAVA - Maven 프로젝트에서 스케줄러 구성하기(Mybatis 연결) - 3 (0) | 2020.05.26 |
| JAVA - Maven 프로젝트에 스케줄러 구성하기 - 2(로그설정, log4j) (0) | 2020.05.26 |
| JAVA - Maven 프로젝트에서 스케줄러 구성하기(Quartz) - 1 (0) | 2020.05.26 |
