分类: Java
2007-11-08 18:26:50

/** *//**
* @(#)Server.java
*
* Server application
*
* @author
* @version 1.00 2007/4/16
*/
import java.net.*;
import java.io.*;

public class Server ...{

public static void main(String[] args) ...{
DatagramPacket pack=null;
DatagramSocket mailReceive=null;
ServerThread thread;
byte b[]=new byte[8192];
InetAddress address=null;
System.out.println("server is running");
pack=new DatagramPacket(b,b.length);

try ...{
mailReceive=new DatagramSocket(7000);
System.out.println("socket build");
}
catch(IOException e)
...{
e.printStackTrace();
}
while(true)...{
try ...{
mailReceive.receive(pack);
address=pack.getAddress();
System.out.println("get client address:"+address);
}
catch(IOException e)...{
System.out.println("error is here");
}
if(address!=null)
...{
System.out.println("get address");
new ServerThread(address).start();
}
else
...{
System.out.println("can't get address");
continue;
}
}
}
}
class ServerThread extends Thread
...{
InetAddress address;
DataOutputStream out=null;
DataInputStream in=null;
String s=null;
ServerThread(InetAddress address)
...{
this.address=address;
}
public void run()
...{
FileInputStream in;
byte b[]=new byte[8192];
try ...{
in=new FileInputStream("a.jpg");
int n=-1;
while((n=in.read(b))!=-1)
...{
DatagramPacket data=new DatagramPacket(b,b.length,address,5678);
DatagramSocket mailSend=new DatagramSocket();
mailSend.send(data);
System.out.println("read image");
}
in.close();
byte end[]="end".getBytes();
DatagramPacket data=new DatagramPacket(end,end.length,address,5678);
DatagramSocket mailSend=new DatagramSocket();
mailSend.send(data);
System.out.println("send all image data ok");
}
catch(Exception e)...{
e.printStackTrace();
}
}
}转自:http://blog.csdn.net/pony1976bj/archive/2007/04/18/1568722.aspx