Java Socket应用---通信是这样练成的_技术笔记

都是已存在 2022-03-11

基于UDP的Socket通信实现多线程：

/**
*服务器端
*/
package com.imooc.UDPTest;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class Server {
    public static void main(String[] args) throws IOException {
        //创建服务器端DatagramSocket,指定端口
        DatagramSocket socket=new DatagramSocket(8800);
        byte[] data=new byte[1024];
        DatagramPacket packet=new DatagramPacket(data,data.length);
        System.out.println("服务器端已经启动，等待客户端发送数据");
        int count=0;
        while (true){
            socket.receive(packet);//此方法在接收到数据包之前会一直堵塞
            Thread serverThread=new ServerThread(socket,packet,data);
            serverThread.start();
            InetAddress address=packet.getAddress();
            System.out.println("当前客户端IP:"+address.getHostAddress());
            count++;
            System.out.println("当前客户端数量:"+count);
        }

    }
}

/**
*服务器线程处理类
*/
package com.imooc.UDPTest;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;


public class ServerThread extends Thread{
    DatagramSocket socket=null;
    DatagramPacket packet=null;
    byte[] data=null;
    public ServerThread(DatagramSocket socket,DatagramPacket packet,byte[] data){
        this.socket=socket;
        this.packet=packet;
        this.data=data;
    }
    public void run() {
        String info=new String(data,0,packet.getLength());
        System.out.println("我是服务器，客户端说:"+info);
        InetAddress address=packet.getAddress();
        int port=packet.getPort();
        data="欢迎您".getBytes();
        packet=new DatagramPacket(data,data.length,address,port);
        try {
            socket.send(packet);
        } catch (IOException e) {
            e.printStackTrace();
        }


    }

}

/**
*客户端
*/
package com.imooc.UDPTest;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class Client {
    public static void main(String[] args) throws IOException {
        //定义服务器的地址、端口号、数据
        InetAddress address=InetAddress.getByName("DESKTOP-M8K8E0E");
        int port=8800;
        byte[] data="用户名：admin;密码:123".getBytes();
        //创建数据报，包含发送的数据信息
        DatagramPacket packet=new DatagramPacket(data,data.length,address,port);
        //创建DatagramSocket对象
        DatagramSocket socket=new DatagramSocket();
        socket.send(packet);

        byte[] data1=new byte[1024];
        DatagramPacket packet1=new DatagramPacket(data1,data1.length);
        socket.receive(packet1);
        String info=new String(data1,0,packet1.getLength());
        System.out.println("我是客户端，服务器说:"+info);
        socket.close();

    }
}

0赞 · 0采集

Mr_WeiS 2020-07-07

基于udp多线程通信

0赞 · 0采集
ciicjsb 2020-05-03

客户端接收服务端的响应代码

截图
0赞 · 0采集
ciicjsb 2020-05-03

服务端向客户端响应的代码

截图
0赞 · 0采集
ciicjsb 2020-05-03

UDP客户端代码

截图
0赞 · 0采集

山木嘉 2019-04-25

基于UDP的Socket通信

客户端：

1.定义发送信息

InetAddress address=InetAddress.getByName("localhost");
  int port=8800;
  byte[] data="用户名：admin;密码：123".getBytes();

2.创建DatagramPacket，包含将要发送的信息

DatagramPacket packet=new DatagramPacket(data,data.length,address,port);

3.创建DatagramSocket

DatagramSocket socket=new DatagramSocket();

4.发送数据

socket.send(packet);

0赞 · 0采集

爱吃娃娃菜的阿菜 2019-01-24

socket实现UDP编程

截图
0赞 · 0采集
Mr_Dolphin 2018-12-15

基于UDP的Socket通信之客户端

截图
0赞 · 0采集
泪M累 2018-12-04

UDP客户端实现

截图
0赞 · 0采集

Fire的草莓 2018-08-09

基于UDP的多线程登陆

/**
* 服务器端，实现基于UDP的用户登录 
* @author Strawberry 
*
*/
public class Test006_UDPServer {	
    public static void main(String[] args) throws IOException {
    //创建服务器DatagramSocket，并指定端口		
    DatagramSocket datagramSocket=new DatagramSocket(8800);		
    //创建数据报，用于接收客户端信息		
    byte[] data=new byte[1024];		
    int count=0;		
    System.out.println("***Server start, waiting data from client..***");		
    //开始接收客户端信息		
       while(true){			
          DatagramPacket datagramPacket=new DatagramPacket(data, data.length);			
          datagramSocket.receive(datagramPacket);//此方法在接收到数据报之前会一直阻塞			
          Test006_ServerThread serverThread=new Test006_ServerThread(datagramSocket, datagramPacket);			
          serverThread.start();			
          count++;			
          System.out.println("client connected:"+count);			
          serverThread.sendData();		
       }				
   //关闭资源
   //datagramSocket.close();	
  }
}

/** 
*  线程处理类 
* @author Strawberry 
* 
*/
public class Test006_ServerThread extends Thread{	
  DatagramSocket datagramSocket=null;	
  DatagramPacket datagramPacket=null;		
  
  public Test006_ServerThread(DatagramSocket datagramSocket,DatagramPacket datagramPacket){				
      this.datagramSocket=datagramSocket;		
      this.datagramPacket=datagramPacket;	
  }	
  
  public void run(){			
      //接收客户端信息			
      byte[] data=datagramPacket.getData();			
      String info=new String(data, 0, datagramPacket.getLength());			
      System.out.println("[Info from client]:   "+info);	
  }	
      
  public void sendData(){		
       //响应客户端信息		
      try {			
          InetAddress address=datagramPacket.getAddress();			
          int port=datagramPacket.getPort();			
          String info2="Login Success!";			
          byte[] data2=info2.getBytes();			
          DatagramPacket datagramPacket2=new DatagramPacket(data2, data2.length, address, port);			
          datagramSocket.send(datagramPacket2);		
      } catch (IOException e) {			
          // TODO Auto-generated catch block			
          e.printStackTrace();		
      }	
  }
}

1赞 · 0采集

CLSTZH 2018-08-02

基于UDP客户端实现：
//1、定义服务器的地址、端口号、数据
InetAddress address=InetAddress.getByName("localhost");
int port=8800;
byte[] data="用户名：admin;密码：123".getBytes();
//2、创建数据报，包含发送的数据信息
DatagramPacket packet=new DatagramPacket(data, data.length,address,port);
//3、创建DatagramSocket对象
DatagramSocket socket=new DatagramSocket();
//4、向服务器端发送数据报
socket.send(packet);

0赞 · 0采集
pxk_java学习之路 2018-06-12

UDP通信客户端接收服务器端响应的数据

截图
0赞 · 0采集
pxk_java学习之路 2018-06-12

UDP通信服务器端响应客户端实现代码<br />

截图
0赞 · 0采集
pxk_java学习之路 2018-06-12

UPD通信客户端实现代码

截图
0赞 · 0采集
深山老龟 2018-04-15

1

截图
0赞 · 0采集
深山老龟 2018-04-15

2

截图
0赞 · 0采集
慕粉1205231228 2018-04-05
InetAddress address=packet.getAddress();
int port=packet.getPort();
byte[] data2="欢迎您!".getBytes();
//2.创建数据报，包含响应的数据信息
DatagramPacket packet2=new DatagramPacket(data2, data2.length, address, port);
//3.响应客户端
socket.send(packet2);
//4.关闭资源
socket.close();
0赞 · 0采集
王雨辰1 2018-03-29

while(true) {
Thread thread=new Thread(new UDPServerThread(socket,data));
thread.start();
try {
thread.sleep(500);
//线程的run方法中无死循环,在main方法中开启线程//并放入死循环中，若不加sleep方法，则警告线程无法正确启动
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
[2.321s][warning][os,thread] Failed to start thread - _beginthreadex failed (EACCES) for attributes: stacksize: default, flags: CREATE_SUSPENDED STACK_SIZE_PARAM_IS.
Exception in thread "main" ????????????????????????
package com.one;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

public class UDPServerThread implements Runnable{

private byte []data=null;
private DatagramSocket socket;

public UDPServerThread(DatagramSocket socket,byte []data) {
this.data=data;
this.socket=socket;
}

@Override
public void run() {
DatagramPacket packet=new DatagramPacket(data, 0, data.length);
try {
socket.receive(packet);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//4.打印输出客户端发送的数据
String s=new String(data, 0, packet.getLength());
System.out.println("我是服务器，客户端说:"+s);

/*
* 向客户端响应数据
*/
int port=packet.getPort();
InetAddress address=packet.getAddress();
byte []data2="欢迎你".getBytes();
DatagramPacket packet1=new DatagramPacket(data2, 0, data2.length, address, port);
try {
socket.send(packet1);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}

截图
0赞 · 0采集
8386728633589209 2018-03-12

tcp协议和udp协议的差别 TCP UDP 是否连接面向连接面向非连接传输可靠性可靠不可靠应用场合传输大量数据少量数据速度慢快

0赞 · 0采集
Kelly_SZ 2018-01-14

UDP客户端传递数据

截图
0赞 · 1采集
Kelly_SZ 2018-01-14

udp客户端传递数据

截图
0赞 · 1采集
Kelly_SZ 2018-01-14

udp服务器响应数据

截图
0赞 · 1采集
qq_奥斯特_0 2018-01-02

qqq

截图
0赞 · 0采集
qq_康_18 2017-11-18

udp是把穿输的数据打包放在数据报报中传输

截图
0赞 · 0采集
木木嗷 2017-09-18

UDP编程-服务器向客户端响应数据（与客户端向服务器发送数据类似） 1、定义客户端的地址、端口号、数据。通过DatagramPacket的.getAddress()方法获取客户端的地址，通过.getPort()方法获取端口号。 2、创建数据报DatagramPacket，包含响应的数据信息。 3、响应客户端。调用DatagramSocket的.send()方法。 4、关闭资源 UDP编程-客户端接受服务器端响应的数据 1、创建数据报DatagramPacket，用于接受服务器端响应的数据。首先创建一个字节数组。 2、接受服务器端响应的数据。调用DatagramPacket的.receive()方法。 3、读取数据。将字节数组转变为字符串。 4、关闭资源。

0赞 · 1采集
木木嗷 2017-09-18

向服务器端发送数据 //1.定义服务器的地址、端口号、数据 InetAddress address=InetAddress.getByName("localhost"); int port=8800; byte[] data="用户名：admin;密码：123".getBytes(); //2.创建数据报，包含发送的数据信息 DatagramPacket packet=new DatagramPacket(data, data.length, address, port); //3.创建DatagramSocket对象 DatagramSocket socket=new DatagramSocket(); //4.向服务器端发送数据报 socket.send(packet); 接收客户端发送的数据 //1.创建服务器端DatagramSocket，指定端口 DatagramSocket socket=new DatagramSocket(8800); //2.创建数据报，用于接收客户端发送的数据 byte[] data =new byte[1024];//创建字节数组，指定接收的数据包的大小 DatagramPacket packet=new DatagramPacket(data, data.length); //3.接收客户端发送的数据 System.out.println("****服务器端已经启动，等待客户端发送数据"); socket.receive(packet); //4.读取数据 String info=new String(data, 0, packet.getLength()); System.out.println("我是服务器，客户端说："+info);

0赞 · 0采集
慕数据5041294 2017-08-01

客户端 1.定义服务器的地址、端口号、数据 InetAddress address=InetAddress.getByName("localhost"); int port=8800; byte[]data="用户名：admin;密码：123".getBytes(); //创建数据报，包含发送的数据信息 DatagramPacket packet=new DatagramPakcet(data,data.length,address,port); //创建DatagramSocket的对象 DatagramSocket socket=new DatagramSocket(); //向服务器发送数据报 socket.send(packet); //接收服务器发送过来的消息 //创建数据报，用于接收服务器响应的数据 byte[]data2=new byte[1024]; DatagramPacket packet2=new DatagramPacket(data2,data2.length); //接收服务器响应的数据 socket.receive(packet2); //读取数据 String reply=new String(data2,0,packet2.getLength()); System.out.println("我是客户端，服务器说："+reply); //关闭资源 socket.close(); -------------------------------------- 服务端响应数据 //定义客户端的地址、端口号、数据 IneetAddress address=packet.getAddress(); int port=packet.getPort(); byte[]data2="欢迎你！".getBytes(); //创建数据报，包含响应的数据信息 DatagramPacket packet2=new DatagramPacket(data2,data2.length,address,port); //响应客户端 socket.send(packet2); //关闭资源 socket.close();

1赞 · 0采集
亨利_慕粉4190963 2017-06-01

客户端： package udp; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; /** * UDP客户端 * @author Administrator * */ public class UDPClient { public static void main(String[] args) throws IOException { //1.定义服务器的地址、端口号、数据 InetAddress address=InetAddress.getByName("localhost"); int port=8800; byte[] data="用户名：admin;密码：123".getBytes(); //2.创建数据报，包含发送的信息，服务器地址，端口，数据 DatagramPacket packet=new DatagramPacket(data, data.length, address, port); //3.创建DatagramSocket对象 DatagramSocket socket=new DatagramSocket(); //4.向服务器端发送数据报 socket.send(packet); /** * 接受服务器端的响应 */ //1.创建数据报，用于接受服务器端响应数据 byte[]data2=new byte[1024]; DatagramPacket packet2=new DatagramPacket(data2, data2.length); //2.接受数据 socket.receive(packet2); //3.读取数据 String reply=new String(data2,0,packet2.getLength()); System.out.println("我是客户端，服务器说："+reply); //4.关闭资源 socket.close(); } }

1赞 · 0采集
亨利_慕粉4190963 2017-06-01

package udp; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; /** * 服务器端，实现基于UDP的用户登录 * * @author Administrator * */ public class UDPServer { public static void main(String[] args) throws IOException { // 1.创建服务器端datagramSocket,指定端口 DatagramSocket socket = new DatagramSocket(8800); int count=0; while (true) { /** * 接受客户端的数据 */ // 2.创建数据报，用于接受客户端发送的信息 byte[] data = new byte[1024];// 创建字节数组，指定接受的数据报的大小 DatagramPacket packet = new DatagramPacket(data, data.length); // 3.接受客户端发送的数据报 socket.receive(packet);// 此方法在接受到数据报之前会阻塞 UDPServerThread serverThread=new UDPServerThread(socket, packet); serverThread.start(); count++; //输出客户端的地址 System.out.println("客户端地址"+count+":"+packet.getAddress()); } // //4.关闭资源 // socket.close(); } }

1赞 · 2采集
亨利_慕粉4190963 2017-06-01

UDP多线程通信：服务器端线程： package udp; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; /** * UDP多线程通信 * @author henry * */ public class UDPServerThread extends Thread { private DatagramSocket socket = null; private DatagramPacket packet=null; public UDPServerThread(DatagramSocket socket,DatagramPacket packet) { this.socket = socket; this.packet=packet; } public void run() { try { // 4.读取数据 String info = new String(packet.getData(), 0, packet.getLength()); System.out.println("我是服务器，客户端说：" + info); /** * 向客户端响应 */ // 1.定义客户端的地址、端口号数据 InetAddress address = packet.getAddress(); int port = packet.getPort(); byte[] data2 = "欢迎您".getBytes(); // 2.创建数据报，包含相应的数据信息 DatagramPacket packet2 = new DatagramPacket(data2, data2.length, address, port); // 3.响应客户端 socket.send(packet2); } catch (IOException e) { e.printStackTrace(); } } }

2赞 · 0采集

数据加载中...