Java_网络编程 - 黑马程序员技术交流社区

package com.heima.udp;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.util.Scanner;

public class Demo03_ThreadSocket {

/**

   * 多线程实现UDP传输

   * @param args

   */

public static void main(String[] args) {

new Send().start();  //启动发送端线程

new Receive().start(); //启动接受端线程

}

}

class Send extends Thread { //发送端

public void run() {

try {

DatagramSocket socket = new DatagramSocket(); //创建套接字对象  相当于码头

Scanner sc = new Scanner(System.in); //键盘录入

while(true) {

String line = sc.nextLine(); //获取录入信息

byte[] b = line.getBytes();  //将录入信息转换为字节数组

DatagramPacket packet = new DatagramPacket(

b, b.length, InetAddress.getByName("127.0.0.1"), 5555);//数据报包  相当于集装箱

socket.send(packet); //发送数据报包  发货

if("quit".equals(line)) { //如果输入的字符串的内容 == "quit"就结束该循环

break;

}

}

socket.close(); //关闭套接字

} catch (Exception e) {

e.printStackTrace();

}

}

}

class Receive extends Thread { //接收端

public void run() {

try {

DatagramSocket socket = new DatagramSocket(5555); //创建套接字对象  码头

DatagramPacket packet = new DatagramPacket(new byte[1024], 1024); //用于接受数据报包

while(true) {

socket.receive(packet); //将接收到的数据放入数据包中

byte[] b = packet.getData(); //获取数据的字节数组

int len = packet.getLength(); //获取数据的有效长度

String addr = packet.getAddress().getHostAddress(); //获取本地ip地址

System.out.println(addr);

if("quit".equals(new String(b,0,len))) {

break;

}

}

socket.close(); //

} catch (Exception e) {

e.printStackTrace();

}

}

}
复制代码

6.TCP协议
（1）客户端
   创建Socket连接服务端(指定ip地址,端口号)通过ip地址找对应的服务器。
   调用Socket的getInputStream()和getOutputStream()方法获取和服务端相连的IO流。
   输入流可以读取服务端输出流写出的数据。
   输出流可以写出数据到服务端的输入流。

创建客户端连接
package com.heima.tcp;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.Socket;

public class Demo01_Client {

/**

   * 客户端

   * Socket(String host, int port) 创建一个流套接字并将其连接到指定主机上的指定端口号。

   *

   * getInputStream()  返回此套接字的输入流。

   *

   * getOutputStream() 返回此套接字的输出流。

   *

   * close() 关闭此套接字。

   */

public static void main(String[] args) throws Exception {

Socket socket = new Socket("127.0.0.1", 12345);  //创建客户端，指定要连接的服务器ip和端口号

InputStream is = socket.getInputStream(); //获取客户端输入流

OutputStream os = socket.getOutputStream(); //获取客户端输出流

byte[] arr = new byte[1024]; //创建输入流缓冲区

int len = is.read(arr);    //读取服务器发过来的数据

System.out.println(new String(arr,0,len));

os.write("hello".getBytes()); //向服务器发送数据

socket.close();

}

}
复制代码

（2）服务端
   创建ServerSocket(需要指定端口号)。
   调用ServerSocket的accept()方法接收一个客户端请求，得到一个Socket。
   调用Socket的getInputStream()和getOutputStream()方法获取和客户端相连的IO流。
   输入流可以读取客户端输出流写出的数据。
   输出流可以写出数据到客户端的输入流。

创建服务器端连接

package com.heima.tcp;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Demo01_Server {
/**
* 服务器端
* ServerSocket(int port) 创建绑定到特定端口的服务器套接字。
*
* accept() 侦听并接受到此套接字的连接。
*
* getInputStream() 返回此套接字的输入流。
*
* getOutputStream() 返回此套接字的输出流。
*
* close() 关闭此套接字。
*/
public static void main(String[] args) throws Exception {
ServerSocket server = new ServerSocket(12345); //指定服务器端口
Socket socket = server.accept(); //接受一个客户端的请求，得到一个Socket
InputStream is = socket.getInputStream(); //获取服务器输入流
OutputStream os = socket.getOutputStream(); //获取服务器输出流
os.write("world".getBytes());
byte[] b = new byte[1024];
int len = is.read(b);
System.out.println(new String(b, 0, len));
server.close();
}
}

复制代码