1.单向通信实现
传输示意图
客户端程序
1 import java.io.DataInputStream; 2 import java.io.DataOutputStream; 3 import java.io.IOException; 4 import java.io.InputStream; 5 import java.io.OutputStream; 6 import java.net.Socket; 7 8 public class clinet { 9 10 public static void main(String[] args) throws IOException { 11 //创建Socket对象 12 Socket clinet = new Socket("127.0.0.1",9999); 13 //获取输出流 14 DataOutputStream dos = new DataOutputStream(clinet.getOutputStream()); 15 dos.writeUTF("hello word!"); 16 //获取输入流 17 DataInputStream dis = new DataInputStream(clinet.getInputStream()); 18 System.out.println(dis.readUTF()); 19 //关闭流 20 if(dis != null) { 21 dis.close(); 22 } 23 if(dos != null) { 24 dos.close(); 25 } 26 if(clinet != null) { 27 clinet.close(); 28 } 29 } 30 }
服务器程序
1 import java.io.DataInputStream; 2 import java.io.DataOutputStream; 3 import java.io.IOException; 4 import java.io.InputStream; 5 import java.io.OutputStream; 6 import java.net.ServerSocket; 7 import java.net.Socket; 8 9 public class Server { 10 11 public static void main(String[] args) throws IOException { 12 System.out.println("-----------服务器端已启动----------"); 13 //创建ServerSocket对象 14 ServerSocket server = new ServerSocket(9999); 15 //监听是否有客户端请求连接 16 Socket clinet = server.accept(); 17 //获取输入流 18 DataInputStream dis = new DataInputStream(clinet.getInputStream()); 19 System.out.println(dis.readUTF()); 20 //获取输出流 21 DataOutputStream dos = new DataOutputStream(clinet.getOutputStream()); 22 dos.writeUTF("收到了"); 23 //关闭流，关闭Socket 24 if(dos != null) { 25 dos.close(); 26 } 27 if(dis != null) { 28 dis.close(); 29 } 30 clinet.close(); 31 } 32 33 }
先启动服务器，再启动客户端
服务器：
客户端：
2.模拟用户登陆
服务器
1 import java.io.DataOutputStream; 2 import java.io.IOException; 3 import java.io.ObjectInputStream; 4 import java.net.ServerSocket; 5 import java.net.Socket; 6 7 import javax.swing.plaf.synth.SynthSeparatorUI; 8 9 import org.omg.PortableInterceptor.DISCARDING; 10 11 public class Server2 { 12 13 public static void main(String[] args) throws IOException, ClassNotFoundException { 14 System.out.println("------服务器端已启动----------"); 15 //创建ServerSocket对象 16 ServerSocket server = new ServerSocket(10000); 17 Socket socket = server.accept(); 18 //获取输入流（对象流） 19 ObjectInputStream ois = new ObjectInputStream(socket.getInputStream()); 20 //对用户名和密码进行验证 21 User user = (User)ois.readObject(); 22 System.out.println(socket.getInetAddress().getHostAddress()+"请求登陆：用户名"+user.getUsername()+" 密码："+user.getPassword()); 23 String str = ""; 24 if("chb".equals(user.getUsername())&&"123456".equals(user.getPassword())) { 25 str = "登陆成功"; 26 }else { 27 str = "登陆失败"; 28 } 29 //获取输出流（数据流） 30 DataOutputStream dos = new DataOutputStream(socket.getOutputStream()); 31 dos.writeUTF(str); 32 //关闭流 33 if(dos != null) { 34 dos.close(); 35 } 36 if(ois != null) { 37 ois.close(); 38 } 39 socket.close(); 40 } 41 42 }
客户端
1 import java.io.DataInputStream; 2 import java.io.IOException; 3 import java.io.ObjectOutputStream; 4 import java.net.Socket; 5 import java.util.Scanner; 6 7 public class Clint2 { 8 9 public static void main(String[] args) throws IOException { 10 //(1)创建Socket对象，用于连接服务器 11 Socket clint = new Socket("localhost", 10000); 12 //(2)获取输出流（对象流） 13 ObjectOutputStream oos = new ObjectOutputStream(clint.getOutputStream()); 14 //(3)创建User对象 15 User user = getUser(); 16 //(4)User对象发生到服务器 17 oos.writeObject(user); 18 //(5)获取输入流（数据流） 19 DataInputStream dis = new DataInputStream(clint.getInputStream()); 20 System.out.println(dis.readUTF()); 21 if(dis != null) { 22 dis.close(); 23 } 24 if(oos != null) { 25 oos.close(); 26 } 27 clint.close(); 28 } 29 public static User getUser() { 30 Scanner input = new Scanner(System.in); 31 System.out.println("请输入用户名："); 32 String username = input.next(); 33 System.out.println("请输入密码："); 34 String password = input.next(); 35 //封装成User对象 36 return new User(username, password); 37 } 38 }
3.UDP 通信_DatagramSocket 实现_客户咨询
1) 不需要利用 IO 流实现数据的传输
2) 每个数据发送单元被统一封装成数据包的方式，发送方将数据包发送到网络中，数据包在网络中去寻找他的目的地。
3) DatagramSocket：用于发送或接收数据包
4) DatagramPacket：数据包
1 import java.io.IOException;
2 import java.net.DatagramPacket;
3 import java.net.DatagramSocket;
4
5 public class Test1 {
6 //接收方
7 /** 一收，
8 * 一发
9 * @throws IOException
10 */
11 public static void main(String[] args) throws IOException {
12 System.out.println("客服人员");
13 DatagramSocket ds=new DatagramSocket(9999);
14 //准 备接收数据
15 byte [] buf=new byte[1024];
16 //准 备数据报接收
17 DatagramPacket dp=new DatagramPacket(buf, buf.length);
18
19 //接收
20 ds.receive(dp);
21
22 //查看接收到的数据
23 String str=new String(dp.getData(),0,dp.getLength());
24 System.out.println("客户说:"+str);
25
26
27 /**回复数据*/
28 byte [] buf2="welcome to beijing".getBytes();//发生的内容 长度 地址 端口号
29 DatagramPacket dp2=new DatagramPacket(buf2, buf2.length, dp.getAddress(), dp.getPort());
30 ds.send(dp2);
31 //关闭
32 ds.close();
33
34
35 }
36 }
1 import java.io.IOException;
2 import java.net.DatagramPacket;
3 import java.net.DatagramSocket;
4 import java.util.Scanner;
5
6 public class Test2 {
7 //
8 /** 一收，
9 * 一发
10 * @throws IOException
11 */
12 public static void main(String[] args) throws IOException {
13 Scanner input=new Scanner(System.in);
14 System.out.println("客服人员");
15 DatagramSocket ds=new DatagramSocket(9999);
16 while(true){
17 //准 备接收数据
18 byte [] buf=new byte[1024];
19 //准 备数据报接收
20 DatagramPacket dp=new DatagramPacket(buf, buf.length);
21
22 //接收
23 ds.receive(dp);
24
25 //查看接收到的数据
26 String str=new String(dp.getData(),0,dp.getLength());
27 System.out.println("客户说:"+str);
28
29 String s=input.next();
30 /**回复数据*/
31 byte [] buf2=s.getBytes();
32 DatagramPacket dp2=new DatagramPacket(buf2, buf2.length, dp.getAddress(), dp.getPort());
33 ds.send(dp2);
34 if("bye".equals(s)){
35 break;
36 }
37 }
38 //关闭
39
40 ds.close();
41
42
43 }
44 }