版权声明:本文为博主原创文章,如有错误劳烦指正。转载请声明出处,便于读取最新内容。——Bestcxx https://blog.csdn.net/bestcxx/article/details/86774961
文章目录
前言
socket 是全双工传输模式,在不启用多线程的情况下,这种功效并不能立即体现出来,即客户端发送-服务端接收-服务端发送-客户端接收需要有序进行。
在 IDE 实现一问一答式聊天
如果你有一个程序员朋友,懂一点 Java 开发,恰巧他/她的电脑安装有 eclipse 或者 idea ,那么可以借助于本文的代码在你们的 ide 里实现一问一答式的聊天。
每次只能说一句,不限制交互次数。
代码
服务端和客户端都只是一个类,运行各自的 main 方法即可。
需要注意的是客户端指定服务器端的 ip 和 端口。
注意客户端和服务器端对字符流的处理编码格式需要一致,否则会出现乱码。
使用了线程池
客户端和服务器端单独指定了编码格式为 UTF8
服务器端和客户端每次输入都自动添加 end 作为发送结束,接收端以此进行判断
服务端
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.nio.charset.Charset;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* socket 服务端
* 一问一答式
* @Author: jie.wu
*/
public class ChatServer {
//使用线程池
private static ExecutorService threadPool= Executors.newFixedThreadPool(5);
//编码格式
private final static String charset="UTF8";
public static void main(String [] args){
ServerSocket serverSocket=null;
Scanner s=new Scanner(System.in);
try{
serverSocket=new ServerSocket(10000);//端口使用 10000
System.out.println("服务端已启动,您本地的字符格式为"+Charset.defaultCharset().name()+",等待客户端访问");
//接收客户端的访问,不限制访问次数
for(;;){
Socket client=serverSocket.accept();
threadPool.execute(new ServerThread(client,s));
}
}catch(Exception e){
System.out.println("报错了1"+e);
}
}
public static class ServerThread implements Runnable{
private Socket socket;//客户端
private Scanner s;
public ServerThread(Socket socket,Scanner s){
this.socket=socket;
this.s=s;
}
InputStream inputStream=null;
BufferedReader bufferedReader=null;
PrintWriter printWriter=null;
@Override
public void run() {
//客户端声明
Socket clientSocket=null;
//客户端输入流声明
InputStream inputStream=null;
BufferedReader bufferedReader =null;
//客户端输出流声明
OutputStream outputStream=null;
PrintWriter printWriter=null;
try{
//初始化客户端
clientSocket=socket;
//初始化客户端输入流
inputStream=clientSocket.getInputStream();
//读取客户端传输的内容
bufferedReader = new BufferedReader(new InputStreamReader(inputStream, charset));
//输出
String str="";
System.out.print("客户端输入:");
//避免使用 readLine 容易造成 阻塞
//服务端会阻塞,使用 readline 方法
for(;(str=bufferedReader.readLine())!=null;){
if("end".equals(str)){
break;
}
System.out.print(str);
}
System.out.println();
/*
char b[]=new char[8192];
StringBuffer sbf=new StringBuffer();
for(int n=0;(n=bufferedReader.read(b,0,n))!=-1;){
sbf.append(b);
}
System.out.println(sbf.toString());
*/
//初始化客户端输出流
outputStream=clientSocket.getOutputStream();
printWriter=new PrintWriter(new OutputStreamWriter(outputStream,charset),true);
//printWriter.println("你好,我是服务器端");
System.out.print("请你输入:");
Scanner s=new Scanner(System.in);
printWriter.println(s.nextLine()+System.getProperty("line.separator")+"end");
System.out.println();
}catch(Exception e){
System.out.println("服务器报错"+e);
}finally {
try{
if(inputStream!=null){
inputStream.close();
}
if(bufferedReader!=null){
bufferedReader.close();
}
if(outputStream!=null){
outputStream.close();
}
if(printWriter!=null){
printWriter.close();
}
}catch(Exception e){
System.out.println("服务器真的报错了"+e);
}
}
}
}
}
客户端
import java.io.*;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.nio.charset.Charset;
import java.util.Scanner;
/**
* socket
* 一问一答式
* 客户端
* @Author: jie.wu
*/
public class Client {
private final static String charset="UTF8";
public static void main(String [] args){
System.out.println("客户端已启动,您本地的字符格式为"+Charset.defaultCharset().name()+",请输入信息:");
Client c=new Client();
//接收客户端的访问-交互20次
for(int i=0;i<20;i++){
c.client();
}
}
public void client(){
Scanner s=new Scanner(System.in);
Socket socket=new Socket();
OutputStream outputStream=null;
PrintWriter printWriter=null;
InputStream inputStream=null;
BufferedReader bufferedReader=null;
try {
//服务端ip和端口
socket.connect(new InetSocketAddress("127.0.0.1", 10000));
//socket.connect(new InetSocketAddress("server.natappfree.cc",36574));
outputStream=socket.getOutputStream();
printWriter=new PrintWriter(new OutputStreamWriter(outputStream, charset),true);
//printWriter.println("你好,我是客户端");
System.out.print("请你输入:");
printWriter.println(s.nextLine()+System.getProperty("line.separator")+"end");
//printWriter.println(s.nextLine());
//printWriter.println("end");
//printWriter.println("end");
inputStream=socket.getInputStream();
bufferedReader=new BufferedReader(new InputStreamReader(inputStream,charset));
//readLine 会造成服务器端阻塞,服务器端要么加以判断主动关闭,要么等待客户端,要么新起一个线程
String str="";
System.out.print("服务端返回:");
for(;(str=bufferedReader.readLine())!=null;){
if("end".equals(str)){
break;
}
System.out.print(str);
}
System.out.println();
/*
char[] b=new char[8192];
StringBuffer sbf=new StringBuffer();
for(int n=0;(n=bufferedReader.read(b,0,n))>-1;){
sbf.append(b);
}
System.out.println(sbf.toString());
*/
}catch(Exception e){
System.out.println("报错了"+e);
}finally {
try{
if(outputStream!=null){
outputStream.close();
}
if(printWriter!=null){
printWriter.close();
}
if(inputStream!=null){
inputStream.close();
}
if(bufferedReader!=null){
bufferedReader.close();
}
}catch(Exception e){
System.out.println("真的报错了"+e);
}
}
}
}
效果
服务端
客户端
跨越局域网实现远程访问本地
一般我们只有一个内网 ip ,这样不足以使远方端朋友运用上面端代码来和我们进行聊天,借助于一个工具,可以将内网 ip 映射到一个临时域名,从而让客户端通过这个临时域名来进行远程访问。
可以获得一个免费的资格
https://blog.csdn.net/bestcxx/article/details/82182107
注意使用 socket 的时候选择 TCP