n("对方发来消息"+buffer.toString()); //将读取到的消息输出
}
}
package duankou;
import java.io.*;
import java.net.*;
import java.util.*;
public class Domekehu { //客户端
static Scanner sc = new Scanner(System.in);
static Socket socket = null;
public static void main(String[] args) throws Exception {
System.out.println("客户端正在尝试连接");
try {
socket = new Socket("127.0.0.1",7878); //链接端口：7878
try {
fayan(); //调用发言方法
} catch (Exception e) {
e.printStackTrace();
}
} catch (Exception e) {
e.printStackTrace();
}
}
private static void fayan() throws Exception { //定义发言方法
System.out.println("链接成功，请发言");
String nei = sc.next(); //输入并传输给服务端
OutputStream output = socket.getOutputStream();
output.write(nei.getBytes());
output.close();
}
}