服务器端:
package TCP实时通讯;
import java.io.*;
import java.net.*;
import java.util.Scanner;
public class TCPServer1 {
static Scanner sc=new Scanner(System.in);
public static void main(String[] args) {
try {
ServerSocket serverSocket = new ServerSocket(9999);
Socket accept = serverSocket.accept();
InputStream inputStream = accept.getInputStream();
OutputStream outputStream = accept.getOutputStream();
outputStream.write("你好哦".getBytes());
while(true){
byte[] bytes=new byte[1024];
int len=inputStream.read(bytes);
if(len==-1){
System.out.println("他说的一句拜拜");
break;
}
String str=new String(bytes,0,len);
System.out.println("客户端说的是:"+str);
System.out.println("服务器说:");
String s1=sc.nextLine();
if(s1.equals("拜拜")||s1.equals("再见")){
break;
}
outputStream.write(s1.getBytes());
}
System.exit(0);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
客户端:
package TCP实时通讯;
import java.io.*;
import java.net.*;
import java.util.Scanner;
public class TCPClient1 {
static Scanner sc=new Scanner(System.in);
public static void main(String[] args) {
try {
Socket socket = new Socket("****",9999);
OutputStream outputStream = socket.getOutputStream();
InputStream inputStream = socket.getInputStream();
while(true){
byte[] bytes=new byte[1024];
int len=inputStream.read(bytes);
if(len==-1){
break;
}
System.out.println("服务器说的是:"+new String(bytes,0,len));
System.out.println("客户端说的是:");
String s1=sc.nextLine();
if(s1.equals("拜拜")||s1.equals("再见")){
break;
}
outputStream.write(s1.getBytes());
}
System.exit(0);
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}