'java/socket' 카테고리의 글 목록

'java/socket'에 해당되는 글 2건

2012.06.29 DataInputStream 에서 전체 byte[] 읽기
2010.06.30 [socket] - Advanced Socket Programming

2012. 6. 29. 10:38

DataInputStream 에서 전체 byte[] 읽기

OS : linux centos 6.2

서버 구성 : DataInputStream으로 데이터를 읽고, DataOutputStream 으로 데이터 전송.

서버를 윈도우에서 구동하고, 클라이언트 구성 시 BufferReader를 사용해서 readLine()으로 읽으니 문제없이 동작하던 코드가 리눅스로 이관하니 데이터 전송은 문제가 안되는데, 데이터 수신 시 읽을 데이터가 없다고 하더라.. 뭔 짓인지..

어쩔 수 없이 클라이언트 코드를 변경하여 BufferReader 대신 DataInputStream 으로 교체하고 데이터를 수신하려고 하는데, readLine()이 없으니 상당히 귀찮더라. DataInputStream 에서 전체 데이터 읽기 위해서는 아래와 같이 하면 되더라.

ByteArrayOutputStream baos = new ByteArrayOutputStream();
byte byteBuffer[] = new byte[1024];

for(int i; (i=dis.read(byteBuffer)) != -1; )
{
baos.write(byteBuffer, 0, i);
}

byte result[] = baos.toByteArray();

저작자표시 비영리

'java > socket' 카테고리의 다른 글

[socket] - Advanced Socket Programming (0)	2010.06.30

Posted by 짱가쟁이

2010. 6. 30. 09:55

java/socket

[socket] - Advanced Socket Programming

출처

http://java.sun.com/developer/technicalArticles/ALT/sockets/#9/

위 기사는 Object serialization 를 사용하여 object를 로컬에 파일로 저장하거나 socket으로 전송하는 단순한 example 을 보여주고 있다.

java.io.Serializable
 객체를 implement 한 클래스를 소켓으로 어떻게 송/수신 한는지 보여주는 샘플을 간단히 정리해 보았다.

Server
ObjectInputStream : readObject() 메소드를 사용하여 input stream 객체를 reading 한다.
ObjectOutputStream : writeObject() 메소드를 사용하여 output stream 객체를 writing 한다.

ObjectServer.java
- 무조건 요청을 받아주는 무식한 서버.

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

public class ObjectServer extends Thread {

private ServerSocket serverSocket;

public ObjectServer(int port) throws IOException {
serverSocket = new ServerSocket(port);
this.start();
}

public void run() {
while(true) {
Socket client;
try {
System.out.println("Waiting for connections.");
client = serverSocket.accept();
System.out.println("Accepted a connection from: "+client.getInetAddress());
WorkerThread c = new WorkerThread(client);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}

}
}

WorkerThread.java
- 요청을 처리하고 응답값을 보내는 worker thread.

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;

import study.socket.serializing.ResponseVo;
import study.socket.serializing.RequestVo;

public class WorkerThread extends Thread {
private Socket client = null;
// read stream
private ObjectInputStream ois = null;
// write stream
private ObjectOutputStream oos = null;

public WorkerThread() {}

public WorkerThread(Socket clientSocket) {
client = clientSocket;

try {
ois = new ObjectInputStream(client.getInputStream());
oos = new ObjectOutputStream(client.getOutputStream());
} catch(Exception e1) {
try {
client.close();
}catch(Exception e) {
System.out.println(e.getMessage());
}
return;
}
this.start();
}

public void readObject() throws IOException, ClassNotFoundException {
RequestVo requestVo = (RequestVo) ois.readObject();

System.out.println("id:"+requestVo.getId());
System.out.println("msg:"+requestVo.getMsg());
}

public void wirteObject() throws IOException {
ResponseVo responseVo = new ResponseVo();
responseVo.setId("response id");
responseVo.setMsg("응답값 전송했음.. 알아서 처리하삼.");

oos.writeObject(responseVo);
}

public void run() {

try {
readObject();
wirteObject();

oos.flush();
// close streams and connections
ois.close();
oos.close();
client.close();
} catch(Exception e) {}
try {
ois.close();
oos.close();
client.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

Serializing Custom Classes
Serializable interface 를 implements 한 custom class 를 작성한다.

RequestVo.java
- 요청 객체

import java.io.Serializable;

public class RequestVo implements Serializable {

private String id;
private String msg;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
}

ResponseVo.java
- 응답 객체

import java.io.Serializable;

public class ResponseVo implements Serializable {

private String id;
private String msg;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
}

Client

ObjectClient.java

import java.io.*;
import java.net.*;
import java.util.*;

import study.socket.serializing.ResponseVo;
import study.socket.serializing.RequestVo;

public class ObjectClient {

public static void main(String argv[]) {
ObjectOutputStream oos = null;
ObjectInputStream ois = null;
Socket socket = null;

try {
// open a socket connection
socket = new Socket("127.0.0.1", 20001);
// open I/O streams for objects
oos = new ObjectOutputStream(socket.getOutputStream());
ois = new ObjectInputStream(socket.getInputStream());

// send an object to the server
RequestVo requestVo = new RequestVo();
requestVo.setId("request id");
requestVo.setMsg("요청했다.. 빨리 보내라 오바.");
oos.writeObject(requestVo);

// read an object from the server
ResponseVo rcvVo = (ResponseVo) ois.readObject();
System.out.println("id:" + rcvVo.getId());
System.out.println("msg:" + rcvVo.getMsg());
oos.close();
ois.close();
} catch(Exception e) {
System.out.println(e.getMessage());
}
}
}

client.zip