수다닷컴

/**

* 질문이 좀 애매하긴 한데..

* 아래 프로그램은 클라이언트에서 데이터를 발송하면

* 해당 데이터를 서버에서 수신하고 검증(?)하는 절차를 거쳐 해당 데이터의 헤더값만

* 리턴하게 됩니다.

* 그래서 아래와 같이 이것저것 소스를 묶어서 만들어보았는데...

* (거의 그냥 샘플 소스 수준도 안되는~~)

* 데이터 발송은 정상적으로 되는데

* 리턴 메시지 송수신의 문제가 있는지 오류가 발생합니다.
**************

java.net.SocketException: socket closed
at java.net.SocketInputStream.socketRead0(Native Method)
at java.net.SocketInputStream.read(SocketInputStream.java:129)
at sun.nio.cs.StreamDecoder$CharsetSD.readBytes(StreamDecoder.java:408)
at sun.nio.cs.StreamDecoder$CharsetSD.implRead(StreamDecoder.java:450)
at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:182)
at java.io.InputStreamReader.read(InputStreamReader.java:167)
at java.io.BufferedReader.fill(BufferedReader.java:136)
at java.io.BufferedReader.readLine(BufferedReader.java:299)
at java.io.BufferedReader.readLine(BufferedReader.java:362)
at SocketClient.main(SocketClient.java:60)

**************

** 가이드 좀 부탁드리겠습니다.

* 혹 비슷한 업무의 소스가 있으시면 참고로 날려주셔도 좋구요..~~

* 그럼 좋은 주말들 되세요.

/
importjava.io.*;
importjava.net.*;
importjava.util.*;
importjava.text.*;

public class SocketServer {

//main 서비스 실행
public static void main(String[] args) {
ServerSocket ss;
Socket sc;
BufferedReader in; // 서버로의 입력
PrintWriter out; // 클라이언트로의 출력
PrintWriter fileOut; // 파일로 저장처리
String inLine;
StringBuffer inLineBuffer;

try {
//기본 수신 소켓
ss = new ServerSocket(4444);

while(true){
inLineBuffer = new StringBuffer();
// 클라이언트의 접속을 기다림
sc = ss.accept();
System.out.println(LISTEN INFO);
System.out.println(::InetAddress : +sc.getInetAddress());
System.out.println(::LocalPort : +sc.getLocalPort());

// 입출력 스트림을 얻음
in = new BufferedReader(new InputStreamReader(sc.getInputStream()));
out = new PrintWriter(sc.getOutputStream(), true);

fileOut = new PrintWriter(new BufferedWriter(new FileWriter(C:\\temp\\test.txt)));

//데이타 수신을 완료하면 해당 스트림을
//특정 폴더에 파일 형태로 저장하여 놓는다.
while((inLine = in.readLine())!=null) { // 종료시 Ctrl-Z 입력
System.out.println(inLine);
inLineBuffer.append(inLine);
}
in.close();

System.out.println(::Stream Size : +inLineBuffer.length());

out.print(inLineBuffer.toString());
out.close();

fileOut.write(inLineBuffer.toString(), 0, inLineBuffer.toString().length());
fileOut.close();

// 소켓, 스트림, 서버 소켓을 닫는다.
sc.close();
}
}catch(IOException ex) {
ex.printStackTrace();
}
}
}
import java.io.*;
import java.net.*;
import java.util.Properties;

public class SocketClient {
public static void main(String[] args) {
Socket sc;
BufferedReader in; // 클라이언트로의 입력
PrintWriter out; // 서버로의 출력

String inLine = null;

//수신 서버 정보
String host = localhost;
int port = 4444;

String TempFileName = ;

try {
sc = new Socket(host, port); // 소켓연결
out = new PrintWriter(sc.getOutputStream(), true);
in = new BufferedReader(new InputStreamReader(sc.getInputStream()));

TempFileName = TEST.txt

FileInputStream fi = new FileInputStream(C:\\temp\\socket_log\\+TempFileName);

//파일을 읽어서 상대 서버로 전송하여준다.
int size = fi.available();
for(int i = 0; i = size; i++) {
out.print((char)fi.read());
}
fi.close();
out.close();

//파일을 전송하고 나서 해당 응답 레코드를 받는 부분이다.
while((inLine = in.readLine())!=null) { //요부분에서 오류 발생

System.out.println(inLine);
}

in.close();
sc.close();
} catch(IOException ex) {
ex.printStackTrace();
}
}
}p;}
}

신청하기