会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132390个问题

服务端:

package com.sxt;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class TwoWaySocketServer {
    public static void main(String[] args) {
        ServerSocket serverSocket =null;
        Socket socket =null;
        BufferedReader br=null;
        Scanner scanner =null;
        PrintWriter pw =null;
        try {
            //服务器需要监听的端口
            serverSocket = new ServerSocket(8888);
            System.out.println("服务端启动,开始监听....");
            //socket包装erverSocket.accept(),大白话说当监听到客户端来消息时返回给socket。并且启动监听accept();
            socket = serverSocket.accept();
            //读取客户端发来的消息
            ////getInputStream()字节流, InputStreamReader转字符流,BufferedReader转字符串
            br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //创建键盘输入对象
            scanner = new Scanner(System.in);
            //向客户端发送消息
            pw = new PrintWriter(socket.getOutputStream());
            while (true){
                //读取客户端发送的消息
                String str = br.readLine();
                System.out.println("客户端说:"+str);
                /*
                if ("esc".equals(str)){
                    break;
                }
                */
                //键盘输入对象,要向客户端发送信息
                String outPrint = scanner.nextLine();
                pw.println(scanner);
                pw.flush();
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if (serverSocket!= null){
                try {
                    serverSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (socket != null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (br!= null){
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (scanner!= null){
                scanner.close();
            }
            if (pw!=null);
            pw.close();
        }
    }
}

客户端:

package com.sxt;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;

public class TwoWaySocketClient {
    public static void main(String[] args) {
        Socket socket = null;
        Scanner scanner = null;
        PrintWriter pw = null;
        BufferedReader br = null;
        try {
            socket = new Socket("192.168.31.250",8888);
            //创建键盘输入对象
            scanner = new Scanner(System.in);
            //创建向服务器发送消息的输出流对象
            pw = new PrintWriter(socket.getOutputStream());
            //创建向服务器读取消息的输入流对象
            //socket.getInputStream()拿到的是一个字节流,先转字符在转字符串
            br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //使用循环处理数据
            while (true){
                //拿到要对服务器发送的消息
                String strOut = scanner.nextLine();
                //向服务器发送消息
                pw.println(strOut);
                pw.flush();
                //读取服务器发来的消息
                String strInput = br.readLine();
                System.out.println("服务端说"+strInput);
            }

        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if (socket != null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            if (pw != null){
                pw.close();
            }
            if (br != null){
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (scanner != null){
                scanner.close();
            }

        }
    }
}

运行结果:


image.png

1:老师好。我这个服务端说的话怎么是乱码啊,找不到什么原因。

2:还有个问题就是不知道怎么回事,服务端和客户端启动之后发送消息有时候两边的接收不到信息






JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 692楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/IO 流技术(旧) 694楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器(旧) 695楼

import java.io.ByteArrayInputStream;

import java.io.ObjectInputStream;

import java.net.DatagramPacket;

import java.net.DatagramSocket;


//利用UDP发送自定义对象<服务端>

public class UDP_SendPersonObjectTypeServer {

public static void main(String[] args) {

try(DatagramSocket dgs=new DatagramSocket(9999)){

byte[] bb=new byte[1024];

DatagramPacket dgp=new DatagramPacket(bb, bb.length);

//接收数据

dgs.receive(dgp);

//类型转换

try(ObjectInputStream ois =new ObjectInputStream(new ByteArrayInputStream(dgp.getData()))){

Person p=(Person) ois.readObject();

System.out.println(p);

} catch (Exception e) {

e.printStackTrace();

// TODO: handle exception

}

}catch (Exception e) {

e.printStackTrace();

// TODO: handle exception

}

}

}


import java.io.ByteArrayOutputStream;

import java.io.ObjectOutputStream;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetSocketAddress;


public class UDP_SendPersonObjectTypeClient {

public static void main(String[] args) {

try(DatagramSocket dgst=new DatagramSocket(8888);

ByteArrayOutputStream bos=new ByteArrayOutputStream();

ObjectOutputStream oos=new ObjectOutputStream(bos)){

//创建自定义对象

Person p=new Person();

p.setName("张三");

p.setAge(28);

//写出对象

oos.writeObject(p);

byte[] by= bos.toByteArray();

//将数据包装成datagrampacket对象

DatagramPacket dap=new DatagramPacket(by,by.length,new InetSocketAddress("127.0.0.1",9999));

//发送数据

dgst.send(dap);

} catch (Exception e) {

e.printStackTrace();

// TODO: handle exception

}

}

}


老师,请问我这里运行后服务端只收到了这个,是为什么
image.png

JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程 696楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/常用类 698楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 699楼

package com.itbaizhan;

import java.util.Map;
import java.util.Set;
import java.util.TreeMap;
import java.lang.Comparable;

public class TreeMapTest {
    public static  void main(String[] args) {
        //实例化TreeMap
        Map<Userds,String> map = new TreeMap<>();
        Userds u1 = new Userds("zhang",18);
        Userds u2 = new Userds("zhang1",19);
        Userds u3 = new Userds("azhang",19);
        map.put(u1,"young");
        map.put(u2,"young");
        map.put(u3,"oldg");

        Set<Userds> keys = map.keySet();
        for (Userds key :keys){
            System.out.println(key+"------------"+map.get(key));
        }

        System.out.println("--------------------");
        Map<Studrent,String> treemap = new TreeMap<>(new StudentComparator());
        Studrent s1 = new Studrent("zhang",19);
        Studrent s2 = new Studrent("azhang",17);
        Studrent s3 = new Studrent("bzhang",18);
        treemap.put(s1,"admin");
        treemap.put(s2,"admin1");
        treemap.put(s3,"admin2");
        Set<Studrent> key1 = treemap.keySet();
        for (Studrent key:key1){
            System.out.println(key+"------"+treemap.get(key));
        }

    }
}

Userds{username='zhang', userage=18}------------young

Userds{username='azhang', userage=19}------------oldg

Userds{username='zhang1', userage=19}------------young

--------------------

Studrent{name='zhang', age=19}------admin2



Studrent 就列出来一个

JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器(旧) 701楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 702楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/智能电话本项目实战 703楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637