有效沟通问答-【官方】百战程序员_IT在线教育培训机构

com.bjsxtjava.io.BufferedReaderjava.io.IOExceptionjava.io.InputStreamReaderjava.io.PrintWriterjava.net.InetSocketAddressjava.net.ServerSocketjava.net.Socketjava.util.ScannerSend1 Thread{
    Socket Scanner (Socket socketScanner scanner){
        .= socket.= scanner}
    () {
        .sendMsg()}
    (){
PrintWriter pw = {
            pw = PrintWriter(..getOutputStream())() {
                String msg = .nextLine()pw.println(msg)pw.flush()}
        }(Exception e){
            e.printStackTrace()}{
            (!= ) {
                .close()}
            (pw != ) {
                pw.close()}
            (.!= ) {
                {
                    ..close()} (IOException e) {
                    e.printStackTrace()}
            }
        }
    }
}
Receive1 Thread{
    Socket (Socket socket){
        .= socket}
    () {
        .receiveMsg()}
    (){
        BufferedReader br = {
            br = BufferedReader(InputStreamReader(..getInputStream()))() {
                String msg = br.readLine()System..println(+msg)}
        }(Exception e){
            e.printStackTrace()}{
            (br != ) {
                {
                    br.close()} (IOException e) {
                    e.printStackTrace()}
            }
            (.!= ) {
                {
                    ..close()} (IOException e) {
                    e.printStackTrace()}
            }
        }
    }
}
GoodTCP {
    (String[] args) {
        Scanner scanner = ServerSocket serverSocket = Socket socket = {
            scanner = Scanner(System.)System..println()String str = scanner.nextLine()String[] arr = str.split()(.equals(arr[])) {
                System..println(+arr[]+)serverSocket = ServerSocket(Integer.(arr[]))socket = serverSocket.accept()System..println()}{
                socket = Socket(arr[]Integer.(arr[]))System..println()}
            Send1(socketscanner).start()Receive1(socket).start()} (Exception e) {
            e.printStackTrace()}{
            (serverSocket != ) {
                {
                    serverSocket.close()} (IOException e) {
                    e.printStackTrace()}
            }
        }
    }
}

报错异常：

请输入：server,<port>或者：<ip>,<port>

127.0.0.1,8888

java.net.ConnectException: Connection refused: connect

at java.net.DualStackPlainSocketImpl.connect0(Native Method)

at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:75)

at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:476)

at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:218)

at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:200)

at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:162)

at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:394)

at java.net.Socket.connect(Socket.java:606)

at java.net.Socket.connect(Socket.java:555)

at java.net.Socket.<init>(Socket.java:451)

at java.net.Socket.<init>(Socket.java:228)

at com.bjsxt.GoodTCP.main(GoodTCP.java:129)

Process finished with exit code 0

JAVA 全系列/第二阶段：JAVA 基础深化和提高/网络编程（旧） 3829楼

getDeclaredConstructor(Class<?>... parameterTypes)中形参Class<?>... parameterTypes是什么意思

JAVA 全系列/第二阶段：JAVA 基础深化和提高/反射技术 3830楼

请问是否有Java8的中文文档

JAVA 全系列/第二阶段：JAVA 基础深化和提高/IO流技术 3831楼

老师，视频里面说，放馒头时，满了会等待；取馒头时，没有馒头会等待。这2个条件好像永远不能同时满足吧？缓冲区只有一个，要不就是满了，要不就没有满。怎么会对生产者来说是满了，对消费者来说是空了呢？很迷糊

JAVA 全系列/第二阶段：JAVA 基础深化和提高/多线程技术（旧） 3832楼

老师，receive的作用是等待客户端发送消息是吗？

String str=new String(dp.getData(),0,dp.getLength());是有什么作用？

dp.getData(),0,dp.getLength()分别代表了什么意思？

JAVA 全系列/第二阶段：JAVA 基础深化和提高/网络编程（旧） 3833楼

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

public class ChatRoomServer {

//定义公共数据区
public static String buf;
public static void main(String[] args) {
System.out.println("Chat Server Version 1.0");
System.out.println("Listen at 8888");
try (ServerSocket ss = new ServerSocket(8888)) {

while(true){
Socket socket = ss.accept();
System.out.println("连接到 "+socket.getInetAddress());
new ChatReceive(socket).start();
new ChatSend(socket).start();
}
} catch (IOException e) {
throw new RuntimeException(e);
}

}
}

class ChatReceive extends Thread{
private Socket socket;
public ChatReceive(Socket socket){
this.socket = socket;
}

@Override
public void run() {
doChatReceive();
}

public void doChatReceive(){
try(BufferedReader bf = new BufferedReader(new InputStreamReader(socket.getInputStream()))){
while(true){
String str = bf.readLine();
synchronized ("abc"){
ChatRoomServer.buf = "["+socket.getInetAddress()+"]"+ str;
"abc".notifyAll();
}
}
} catch (Exception e) {
e.printStackTrace();
}
}
}

class ChatSend extends Thread{
private Socket socket;
public ChatSend (Socket socket){
this.socket = socket;
}

@Override
public void run() {
sendMsg();
}
private void sendMsg() {
try(PrintWriter pw = new PrintWriter(socket.getOutputStream())){
while (true) {
synchronized ("abc "){
//先让发送消息的线程处于等待状态
"abc".wait();
//将公共数据区中的消息发送给客户端
pw.println(ChatRoomServer.buf);
pw.flush();

}

}
}catch (Exception e){
e.printStackTrace();
}
}
}