服务承诺
资金托管
原创保证
实力保障
24小时客服
使命必达
51Due提供Essay，Paper，Report，Assignment等学科作业的代写与辅导，同时涵盖Personal Statement，转学申请等留学文书代写。
51Due将让你达成学业目标51Due将让你达成学业目标51Due将让你达成学业目标51Due将让你达成学业目标私人订制你的未来职场 世界名企，高端行业岗位等 在新的起点上实现更高水平的发展
积累工作经验
多元化文化交流
专业实操技能
建立人际资源圈Udt_Massage_Sender_Receiver
2013-11-13 来源: 类别: 更多范文
+Client
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.net.ConnectException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
//import java.net.Socket;
import java.net.UnknownHostException;
public class sender{
private static int remotePort;
private static InetAddress remoteIpAddress;
static String sendmsg;
private static DatagramSocket senderSocket ;
private static ObjectOutputStream outToReceiver;
private static BufferedReader inFromUser;
private static DatagramPacket sendpacket;
public static void main(String[] argv) throws UnknownHostException, IOException{
/*
if ( argv.length != 2 ) {
printHelp();
return;
}
*/
String word = null;
BufferedReader inFromUser = new BufferedReader(new InputStreamReader(System.in));
remotePort = 1006;
try {
//192.168.0.4
remoteIpAddress = InetAddress.getLocalHost();
} catch(NumberFormatException ex){
// 적당한 예외 처리
System.err.println(remoteIpAddress + ": invalid Port #");
printHelp();
return;
}catch (UnknownHostException e) {
e.printStackTrace();
}
System.out.println(remoteIpAddress);
try {
senderSocket = new DatagramSocket();
// 소켓 연결
} catch (ConnectException e) {
// 예외 처리 -- receiver 준비 안된 경우
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
System.out.println("Client side Sender ready");
/*try {
sendmsg=inFromUser.readLine();
} catch (IOException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}*/
// stream 준비
//System.out.println(sendbyte);
String buf = null;
while(true){
try {
sendmsg=inFromUser.readLine();
byte[] sendbyte=sendmsg.getBytes();
DatagramPacket sendpacket = new DatagramPacket(sendbyte , sendbyte.length , remoteIpAddress , remotePort);
senderSocket.send(sendpacket);
// and then send to the socket stream
System.out.println("send ok");
/*
//서버로부터 수신
byte[] receivebyte = new byte[1024];
DatagramPacket receivePacket = new DatagramPacket(receivebyte, receivebyte.length);
senderSocket.receive(receivePacket);
String modifiedSentence = new String(receivePacket.getData());
System.out.println("FROM SERVER:" + modifiedSentence);
//서버로부터 수신
*/
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
private static void printHelp() {
System.err.println("Sender ");
System.err.println("where is the address of the Receiver");
}
}
+Server
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ConnectException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;
public class receiver {
private static int receiverPort = 0;
private static Socket receiverSocket = null;
private static ServerSocket welcomeSocket = null;
private static ObjectInputStream inFromSender = null;
private static DatagramSocket receiversocket;
//private static DatagramPacket packet;
private static DatagramPacket packet_return;
private static String getmsg;
private static String returnmsg;
private static InetAddress clientIpAddress;
public static void main(String[] argv) throws IOException {
BufferedReader inFromUser = new BufferedReader(new InputStreamReader(System.in));
/*if ( argv.length != 1 ) {
printHelp();
return;
}*/
receiverPort = 1006;
try {
//receiverPort = Integer.parseInt(argv[0]);
// socket 연결 처리
clientIpAddress = InetAddress.getLocalHost();
receiversocket = new DatagramSocket(receiverPort,clientIpAddress);
}
catch(NumberFormatException ex){
System.err.println( argv[1] + ": invalid Port #");
printHelp();
// 적당한 예외 처리
} catch (IOException e) {
// 적당한 예외 처리
e.printStackTrace();
}
// 스트림 준비
System.out.println("Receiver ready");
while (true) {
byte[] sendbyte=new byte[1024];
//byte[] returnbyte=new byte[1024];
try {
DatagramPacket packet = new DatagramPacket(sendbyte, sendbyte.length);
// read from the socket stream
receiversocket.receive(packet);
// and print to console
getmsg=new String(packet.getData());
System.out.println("received massage - "+getmsg);
/* //로컬에서 다시 전송하면 무한루프돌아버림
returnmsg=getmsg+" - recieve complited";
returnbyte=returnmsg.getBytes();
packet_return = new DatagramPacket(returnbyte, returnbyte.length, clientIpAddress , receiverPort);
receiversocket.send(packet_return);
*/
}
catch (IOException e) {
e.printStackTrace();
break;
}
}
}
private static void printHelp() {
System.err.println("Receiver ");
System.err.println("where is the port number at which the Receiver is listening");
}
}
