UDP Packet을 받을 수가 없어요..그리고, 쓰레드 끼리 데이터를 가져가는지 모르겠어요...

글쓴이 :김용탁 2000년 7월 05일 03:58:44

UDP로 데이터를 받아서, TCP로 접속해 오는 User들에게

데이터를 보내주는 Application을 제작하고 있습니다.

그런데, UDP로 데이터 Packet이 받아지지 않는거예요...

어떻하죠?

또, UDP 쓰레드로 데이터를 받는다 해도,

TCP Server에 해당하는 쓰레드로 데이터를 받게 하는게

어떻게 해보긴 했지만 되는지 안되는 모르겠어요...

정확한 방법이 아닌 것 같거든요...

고수님들...제발..제발...방법 좀 알려주셔요...흑흑

소스를 함께 올립니다.

import java.net.*;
import java.io.*;
import java.lang.*;

public class RealTimeServ implements Runnable
{
static int users = 0;
static int tcpPort = 7965;
static String tKospi;
static String tKospi200;
static String tKosdaq;
static socket_stuff clients[] = new socket_stuff[300];

public static void main(String args[])
{
RealTimeServ rt = new RealTimeServ();
Thread t = new Thread(rt);
t.start();

}

public void run()
{
ServerSocket serverSocket = null;

try
{
serverSocket = new ServerSocket(tcpPort);
}
catch (IOException e)
{
System.out.println("Could not listen on port: " + tcpPort + "," + e);
System.exit(1);
}

Socket clientSocket = null;
connection user = new connection(serverSocket);

if (users == 0)
{
try
{
clientSocket = serverSocket.accept();
}
catch (IOException e)
{
System.out.println("Accept failed: "+ tcpPort + "," + e);
System.exit(1);
}
add_client(new socket_stuff(clientSocket));
}

UDPPacket udp = new UDPPacket();
udp.start();

user.start();

int i;

try
{
i = users;

while (users >= 0)
{
tKospi = udp.pKospi; // <----- 여기서 UDP 데이터를 TCP로 넘겨준다고 생각하고 만들었습니다..맞나요?
tKospi200 = udp.pKospi200;
tKosdaq = udp.pKosdaq;

if (clients[i] != null)
write_all(tKospi+tKospi200+tKosdaq);
try
{
user.join(2);
}
catch (InterruptedException e) {}

if (user.connected() == true)
{
add_client(new socket_stuff(user.get_socket()));
user.resume();
}

i++;

if(i>users && users>=1)
i=1;

if(i>users && users<1)
i=0;

try
{
Thread.sleep(3000);
}
catch (InterruptedException e)
{}
}

serverSocket.close();
} catch (IOException e) {}
}

static void write_all(String text)
{
int i;
for(i=1;i<=users;i++)
clients[i].write_string(text);
}

static void add_client(socket_stuff client)
{
if (users >= 300)
{
client.kill();
return;
}

clients[++users] = client;
}

static void remove_client(int client)
{
clients[client].kill();
clients[client] = clients[users];
clients[users]=null;
users--;
}
}

class connection extends Thread
{
Socket socket = null;
public boolean is_connected = false;
ServerSocket server = null;

connection(ServerSocket server_sock)
{
server = server_sock;
}

boolean connected()
{
return is_connected;
}

Socket get_socket()
{
is_connected = false;
return socket;
}

public void run()
{
while (true)
{
is_connected = false;

if (!is_connected)
{
try
{
socket = server.accept();
} catch(IOException e)
{
System.out.println("Problem with accept");
}

is_connected = true;
this.suspend();
}
}
}
}

class socket_stuff
{
Socket socket;
PrintWriter os;

socket_stuff(Socket client)
{
try
{
os = new PrintWriter(new BufferedOutputStream(client.getOutputStream(),1024),false);
socket = client;
} catch(IOException e) {}
}

public void write_string(String s)
{
os.println(s);
os.flush();
}

public void kill()
{
try
{
if (os != null)
os.close();

if (socket!= null)
socket.close();
} catch (IOException e) {}
}
}

class UDPPacket extends Thread // <--- 여기가 UDP Packet을 받는 Class 인데...안되요..흑흑흑
{
public static String pKospi;
public static String pKospi200;
public static String pKosdaq;

private static int Port = 7859;
private DatagramSocket ds;
private DatagramPacket dp;

public void run()
{
byte[] buffer = new byte[1024];

String line, result;
StringBuffer revline;
int len;

try
{
ds = new DatagramSocket(Port);

for(;;)
{
dp = new DatagramPacket(buffer, buffer.length);
try
{
ds.receive(dp);
line = new String(dp.getData(), 0, 0, dp.getLength());
System.out.println("line: " + line);
len = line.length();
System.out.println("the length of this string :"+len);

redirectPacket(line);
line = null;

try
{
sleep(300);
}
catch (InterruptedException e) {}
}
catch (IOException e)
{
System.err.println(e);
}
}
}
catch (SocketException se)
{
System.err.println(se);
}
}

public static void redirectPacket(String str)
{
String kospi = "I1";
String kospi200 = "I2";
String kosdaq = "OJ";
String head = "01";

int length;
String conhead, conkind;

conhead = str.substring(1, 3);
conkind = str.substring(3, 5);

if (conhead.compareTo(kospi) == 0)
{
if (conkind.compareTo(head) == 0)
{
pKospi = str.substring(12, 18);
System.out.println("pKospi: " + pKospi);
}
}

if (conhead.compareTo(kospi200) == 0)
{
if (conkind.compareTo(head) == 0)
{
pKospi200 = str.substring(12, 18);
System.out.println("pKospi200: " + pKospi200);
}
}

if (conhead.compareTo(kosdaq) == 0)
{
if (conkind.compareTo(head) == 0)
{
pKosdaq = str.substring(10, 16);
System.out.println("pKosdaq: " + pKosdaq);
}
}
}
}

다음 글들:

이어서 글올리기(답하기)