글쓴이 :gyoni 2000년 5월 23일 16:24:23
다음은 자바클라이언트의 소스입니다.
c++로 제작된 윈도우즈서버와 통신하려고 하는데요...
서버로 부터 받는 메시지는 다 받고 보입니다.
문제는 이 클라이언트가 서버에게 뭘 보내면 서버가 응답이 없어요.
다시 말해 c++클라이언트 -- c++서버 -- java클라이언트
형태로 통신하고 있는데요....
자바 클라이언트가 메세지를 보내면 서버가 아무일도 않고 있어요.
그러다 자바 클라이언트를 죽이면 다시 잘 동작됩니다.
c++클라이언트가 보내는 메세지는 자바클라이언트가 잘받아보고요...
아아아......도움이 절실히 필요합니다.
어떠한 이야기라도 제게는 큰 도움이 될것같아요.
import java.net.*;
import java.io.*;
import java.awt.*;
import java.applet.*;
class UTF8 extends Frame implements Runnable {
public static final int PORT = 700;
Socket socket;
InputStreamReader in;
OutputStreamWriter out;
TextField inputfield;
TextArea outputarea;
Thread thread;
UTF8(String title){
super(title);
inputfield = new TextField();
outputarea = new TextArea(10,17);
outputarea.setFont( new Font("Dialog", Font.PLAIN, 12));
outputarea.setEditable(false);
inputfield.setBackground(Color.white);
outputarea.setBackground(Color.white);
}
public static void main(String[] str){
UTF8 pan=new UTF8("0519");
pan.setLayout(new BorderLayout());
pan.add("South", pan.inputfield);
pan.add("Center", pan.outputarea);
pan.setBackground(Color.lightGray);
pan.setForeground(Color.black);
pan.resize(300,300);
pan.show();
try{
pan.socket = new Socket(InetAddress.getByName("***.***.**.*"), PORT); pan.in =new InputStreamReader(pan.socket.getInputStream());
pan.out=new OutputStreamWriter(pan.socket.getOutputStream(),"MS949"); //8bit 스트림생성.
} catch (IOException e){
pan.say("applet-socket-error!");
System.exit(1);
}
pan.say("socket made.");
if (pan.thread == null){
pan.thread = new Thread(pan);
pan.thread.setPriority(Thread.MIN_PRIORITY);
pan.thread.start();
}
pan.say("thread started.");
}
public boolean action(Event e, Object what)
{
if (e.target==inputfield)
{
String inp=(String) e.arg;
writeSocket(inp);
inputfield.setText("");
return true;
}
return false;
}
public void writeSocket(String line){
String str;
str = HURLDecoding(line);
try{
out.write(str,0,str.length());
out.flush();
outputarea.appendText("send:"+str+"("+line+")"+"**Encoding:"+out.getEncoding()+'\n');
}catch(IOException er){outputarea.appendText("Write error"+er+'\n');}
}
public void run()
{
String line;
try
{
while(true)
{
char[] bin = new char[100]; //한글에서 "일이...구"+14 까지 지원. 숫자로는 18+14(=32)자
int readbyte=0;
readbyte=in.read(bin, 0, bin.length);
//stream의 끝에 도달하면, 즉 널이 오면 break
if(readbyte==-1){ outputarea.appendText("total"+readbyte+'\n'); break;}
String input = new String(bin,0,bin.length);
input = input.trim();
outputarea.appendText(input+"**size:"+readbyte+"**excoding:"+in.getEncoding()+'\n');
}
} catch (IOException e) {outputarea.appendText("Read error"+e+'\n'); }
}
public void say(String msg)
{
outputarea.appendText("*** "+msg+" ***\n");
}
public void stop()
{
try
{
socket.close();
} catch (IOException e)
{}
if ((thread !=null) && thread.isAlive())
{
thread.stop();
thread = null;
}
}
/*
* 2바이트를 1바이트로 바꿔주는 모듈
*/
private static char hex2char(char a1, char a2)
{
char r;
int k;
if (a1 >= '0' && a1 <= '9') k = (int)(a1 - '0');
else if (a1 >= 'a' && a1 <= 'f') k = (int)(a1 - 'a' + 10);
else if (a1 >= 'A' && a1 <= 'F') k = (int)(a1 - 'A' + 10);
else k = 0;
k <<= 4;
if (a2 >= '0' && a2 <= '9') k += (int)(a2 - '0');
else if (a2 >= 'a' && a2 <= 'f') k += (int)(a2 - 'a' + 10);
else if (a2 >= 'A' && a2 <= 'F') k += (int)(a2 - 'A' + 10);
else k += 0;
r = (char)k;
return r;
}
private static String URL_Decode(String s)
{
String t = "";
char a;
int i, len;
boolean han_flag = false;
len = s.length();
for (i = 0; i < len; i++) {
a = s.charAt(i);
if (a == '%') {
a = hex2char(s.charAt(i+1), s.charAt(i+2));
i += 2;
}
else if (a == '+') a = ' ';
t += a;
}
return t;
}
private static String HURLDecoding(String s)
{
String t;
t = URL_Decode(URLEncoder.encode(s));
return t;
}
}