1.tcp的实现
socket的服务端
/**
* @Project: 3.DistributedProject
* @description: socket的服务端
* @author: sunkang 一定在流写的时候flush
* 这里printWrite 必须要用println ,因为在写入的时候加上了一个换行符号
*
* @create: 2018-06-27 23:00
* @ModificationHistory who when What
**/
public class ServerSocketDemo {
public static void main(String[] args) {
ServerSocket server = null;
try {
server = new ServerSocket(8083);
Socket socket = server.accept(); //阻塞过程
BufferedReader is = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter os = new PrintWriter(socket.getOutputStream());
BufferedReader sin = new BufferedReader(new InputStreamReader(System.in));
System.out.println("Client:" + is.readLine()); //拿到客户端的信息
String line = sin.readLine();
while (!line.equals("bye")) {
os.println(line);//输出数据
os.flush();
System.out.println("Server:" + line);
System.out.println("Client:" + is.readLine());
line = sin.readLine();
}
os.close();
is.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
} finally {
}
}
}
socket的客户端
/**
* @Project: 3.DistributedProject
* @description: socket的客户端
* @author: sunkang
* @create: 2018-06-27 23:00
* @ModificationHistory who when What
**/
public class SocketDemo {
public static void main(String[] args) {
try {
Socket socket=new Socket("127.0.0.1",8083);
BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));
PrintWriter os=new PrintWriter(socket.getOutputStream());
BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));
String line=sin.readLine();
while(!line.equals("bye")){
os.println(line);
os.flush();
System.out.println("Client:"+line);
System.out.println("Server:"+is.readLine());
line=sin.readLine();
}
os.close();
is.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
} finally {
}
}
}
2.udp的实现
udp 服务端的实现
/**
* @Project: 3.DistributedProject
* @description: udp 服务端的实现
* @author: sunkang
* @create: 2018-06-28 19:05
* @ModificationHistory who when What
**/
public class UdpServerDemo {
public static void main(String[] args) {
try {
byte[] bytes = new byte[1024];
DatagramPacket datagramPacket = new DatagramPacket(bytes,bytes.length);
DatagramSocket datagramSocket = new DatagramSocket(2345);
datagramSocket.receive(datagramPacket);
//打印数据包的内容
System.out.println(new String(bytes,0,datagramPacket.getLength()));
} catch (SocketException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
udp 客户端的实现
/**
* @Project: 3.DistributedProject
* @description: udp 客户端的实现
* @author: sunkang
* @create: 2018-06-28 19:00
* @ModificationHistory who when What
**/
public class UdpClientDemo {
public static void main(String[] args) {
InetAddress inetAddress= null;
try {
inetAddress = InetAddress.getByName("localhost");
byte[] data = "sunkang hello".getBytes();
//数据包携带了包体的字节数据和ip地址以及端口号
DatagramPacket datagramPacket = new DatagramPacket(data,data.length,inetAddress,2345);
DatagramSocket datagramSocket = new DatagramSocket();
datagramSocket.send(datagramPacket);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (SocketException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
