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;
/**
* 发送消息的线程
*/
class Send1 extends Thread{
private Socket socket;
private Scanner scanner;
public Send1(Socket socket,Scanner scanner){
this.socket = socket;
this.scanner = scanner;
}
@Override
public void run() {
this.sendMsg();
}
/**
* 发送消息
*/
private void sendMsg(){
//创建向对方输出消息的流对象
try (PrintWriter pw = new PrintWriter(socket.getOutputStream())){
while (true){
String msg = scanner.nextLine();
pw.println(msg);
pw.flush();
}
}catch (Exception e){
e.printStackTrace();
}
}
}
/**
* 接收消息的线程
*/
class Receive1 extends Thread{
private Socket socket;
public Receive1(Socket socket){
this.socket = socket;
}
@Override
public void run() {
this.receiveMsg();
}
/**
* 接收消息
*/
private void receiveMsg(){
//创建用于接收对方发送消息的流对象
try(BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()))){
while(true){
String msg = br.readLine();
System.out.println("他说："+msg);
}
}catch(Exception e){
e.printStackTrace();
}
}
}
public class GoodTCP {
public static void main(String[] args) {
Scanner scanner = null;
ServerSocket serverSocket = null;
Socket socket = null;
try {
//键盘输入对象
scanner = new Scanner(System.in);
System.out.println("请输入：server,<port> 或者：<ip>,<port>");
String str = scanner.nextLine();
String[] arr = str.split(",");
if ("server".equals(arr[0])){
//启动服务器
System.out.println("TCP Server Listen at "+arr[1]+"......");
serverSocket = new ServerSocket(Integer.parseInt(arr[1]));
socket = serverSocket.accept();
System.out.println("连接成功！");
}else{
//启动客户端
socket = new Socket(arr[0],Integer.parseInt(arr[1]));
System.out.println("连接成功！");
}
//启动发送消息的线程
new Send1(socket,scanner).start();
//启动接收消息的线程
new Receive1(socket).start();
}catch (Exception e){
e.printStackTrace();
}finally {
if(serverSocket != null){
try {
serverSocket.close();
}catch (IOException e){
e.printStackTrace();
}
}
}
}
}
请输入：server,<port> 或者：<ip>,<port>
server，8888
java.lang.ArrayIndexOutOfBoundsException: Index 1 out of bounds for length 1
at GoodTCP.main(GoodTCP.java:88)
老师，这是数组越界吗？我该怎么解决呢？
代码：
老师这个我框起来的地方和mapperLocations有什么区别呀，他们各自都有什么用？
京公网安备 11011402011233号