--------------------------服务端代码--------------------------
public class Server {
private ServerSocket server;
public Server() {
try {
System.out.println("正在启动服务端...");
server = new ServerSocket(8088);
System.out.println("服务端启动完毕！");
}catch(Exception e) {
e.printStackTrace();
}
}
public void start() {
try {
while(true) {
System.out.println("等待客户连接。。。");
Socket socket = server.accept();
System.out.println("一个客户连接");
InputStream in = socket.getInputStream();
int len=-1;
StringBuilder str = new StringBuilder();
//byte数组长度只能设置成3（一个中文字符的长度）才能正确显示中文
byte[] data = new byte[3];
while((len=in.read(data))!=-1) {
str.append(new String(data,0,len,"UTF-8"));
System.out.println(str);
}
System.out.println(str);
}
}catch(Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
Server server = new Server();
server.start();
}
}
--------------------------客户端代码--------------------------
public class Client {
private Socket socket;
public Client() {
try {
/*
* 实例化Socket的过程就是发起连接的过程，若服务端
* 没有响应则这里会直接抛出异常
* "127.0.0.1" 真实ip地址 localhost
*/
System.out.println("正在连接服务端");
socket = new Socket("localhost",8088);
System.out.println("已连接服务端");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void start() {
try {
OutputStream out = socket.getOutputStream();
String str = "我们幸福的生活着";
/*
* 在网上查了很久也没搞清楚，为什么基本字节流OutputStream
* 只要不close()，Server端InputStream的read()方法就不会
* 返回-1表示结束。
* 以下是我的理解。
* 字节流OutputStream的write()方法不会主动发送结束符。唯有
* close该OutputStream，才会给服务端发送结束符。
*/
out.write(str.getBytes("UTF-8"));
out.flush();
//out.close();
while(true) {
System.out.println("请输入：");
Scanner scan = new Scanner(System.in);
String line = scan.nextLine();
out.write(line.getBytes("UTF-8"));
out.flush();
}
}catch(Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
Client client = new Client();
client.start();
}
}
在网上查了很久也没搞清楚，为什么基本字节流OutputStream
只要不close()，Server端InputStream的read()方法就不会
返回-1表示结束。
以下是我的理解。
字节流OutputStream的write()方法不会主动发送结束符。唯有
close该OutputStream，才会给服务端发送结束符。
我想问一下，如何用outputstream和inputstream两个流实现实时的
字符传输。
碰到什么问题呢？最好转换为缓存流，或者字符流，更容易操作。
读到-1,代表没有读到数据，不代表结束。
读文件时，读到-1可以代表结束，是因为读文件是连续的，没有读到数据，可以认为结束。
socket就不能这样判断。客户端连上服务，可以间断的发信息。所以当前没读到数据，不代表后面读不到数据。
流关闭，相当于不再从连接里读数据数了，属于强制关闭，与你说的结束符不是一个概念。
如果需要一个你想要结束符，需要自己定义一个，比如“#”字符，服务端收到客户端发的“#”时，就可以认为客户端不再发消息了。
如果实现实时传输字符，就把服务端的流出传入到一个线程里，让线程循环读取。读到内容，就放到一个消息集合里。
再定义一个线程，从集合不停取消息（有消息，取出来后要删掉，），做后续处理，比如显示到控制台。
这个集合需要是线程安全的。