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

package cn;

import java.io.IOException;
import java.net.*;
import java.util.Scanner;
/**客户端1
*/
public class UDPClient1 {
    public static void main(String[] args) throws IOException {
        //创建DatagramSocket对象
        DatagramSocket ds = new DatagramSocket(8888);//本应用程序端口
        while (true){
            try {
                //准备要发送的数据
                byte[]buf = talk().getBytes();
                //创建数据对象
                DatagramPacket dp1 = new DatagramPacket(
                        buf, buf.length, InetAddress.getByName("localhost"), 9999);
                //发送数据
                ds.send(dp1);
                byte[]buf2 = new byte[8196];
                DatagramPacket dp2 = new DatagramPacket(
                        buf, buf.length);
                ds.receive(dp2);
                System.out.println(new String(dp2.getData()));
                buf2=null;
                buf2 = new byte[1024];//清空残余数据
            } catch (IOException e) {
                e.printStackTrace();
                //关闭
                ds.close();
            }
        }
    }

    /**
     * 用户输入聊天信息
     * @return
     */
    public static String talk(){
        Scanner sc = new Scanner(System.in);
        return "客户端1:"+sc.nextLine();
    }
}
package cn;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;
/**客户端2
*/
public class UDPCLient2 {
    public static void main(String[] args) throws IOException {
        DatagramSocket ds1 = new DatagramSocket(9999);
        byte []buf = new byte[8196];

        while (true){
            DatagramPacket dp1 = new DatagramPacket(
                    buf,buf.length);
            //查看接收到的数据
            ds1.receive(dp1);
            String str = new String(dp1.getData());
            buf=null;//清空残余数据,重新分配新的空间
            buf = new byte[8196];
            System.out.println(str);
            byte[]buf2 = talk().getBytes();
            DatagramPacket dp2 = new DatagramPacket(
                    buf2,buf2.length,dp1.getAddress(),dp1.getPort());
            try {
                ds1.send(dp2);
            } catch (IOException e) {
                e.printStackTrace();
                //关闭流
                ds1.close();
            }
        }
    }

    /**
     * 用户输入聊天信息
     * @return
     */
    public static String talk(){
        Scanner sc = new Scanner(System.in);
        return "客户端2:"+sc.nextLine();
    }
}

    上述代码实现了两个客户端的简单通信。

     但是有BUG,就是两个客户端启动后,只有客户端1给客户端2发送数据后,双方通信才正常。

     原因可能是客户端2在通信前不知道客户端的地址和端口号

     目前暂时找不到解决办法,请老师给指导指导呗,谢谢@_@

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

public class Server {//服务器 用于启动和停止服务
    private ServerSocket server;
    private boolean isShutDown = false; //默认没有出错
    public void start() {
        this.start(8888);
    }
    public void start(int port) {
        try {
            server = new ServerSocket(port);
            this.receive();//调用接收请求信息的方法
        } catch (IOException e) {
            isShutDown = true;
        }
    }
    private void receive() {
        try {
           while(!isShutDown) {
               //(1)监听
               Socket client = server.accept();
               //创建线程类对象
               Dispatcher dis = new Dispatcher(client);
               //创建代理类并启动线程
               new Thread(dis).start();
           }
                      
        } catch (IOException e) {
           this.stop();//关闭服务器
        }
    }
    public void stop() {
        isShutDown = true;
        IOCloseUtil.closeAll(server);
    }
    public static void main(String[] args) {
        Server server = new Server();
        server.start();
    }
}

image.png

老师,麻烦您看一下为什么会出现这个错误


JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 3065楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 3069楼

老师,我这个没有相应成功。这是为啥呀.................


package com.bjsxt.server;


import java.io.BufferedWriter;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStreamWriter;

import java.net.ServerSocket;

import java.net.Socket;


public class Server3 {

public static void main(String[] args) {

String CRLF="\r\f";//换行

String BLANK=" ";

//(1)创建ServerSocket的对象

ServerSocket server=null;

//(2)监听是否有客户端发送请求

Socket client=null;

InputStream is=null;

 

try {

server = new ServerSocket(8888);

client = server.accept();

//获取来自浏览器的请求信息

is=client.getInputStream();

byte[] buf=new byte[20480];

int len=is.read(buf);

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

/*对web浏览器的请求做出相应*/

StringBuilder sb=new StringBuilder();

StringBuilder sbContent=new StringBuilder();//相应的文本

sbContent.append("<html><head><title>相应结果</title></head>");

sbContent.append("<body>登陆成功</body></html>");

//(1)拼接响应头

sb.append("HTTP/1.1").append(BLANK).append(200).append(BLANK).append("OK");

sb.append(CRLF);//换行

sb.append("Content-Type:text/html;charset=utf-8");

sb.append(CRLF);//换行

sb.append("Content-Length:").append(sbContent.toString().getBytes().length).append(CRLF);

sb.append(CRLF);//换行,代表响应头与响应正文部门之间的空行

sb.append(sbContent);

//通过流输出

BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(client.getOutputStream(),"utf-8"));

bw.write(sb.toString());

bw.flush();

bw.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}finally {

//(6)关闭流

IOClose.closeAll( is,client,server);

}

}

}


JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 3070楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/XML 技术(旧) 3072楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术(旧) 3073楼

朴素贝叶斯算法.zip

老师,自己写的朴素贝叶斯算法,得到的结果都是空是怎么回事。具体代码在压缩包中

图片.png

JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器(旧) 3074楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

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