客户端：
多个客户可以正常收发信息，因为可以同时发送和接受信息，不是发送完信息后等待
返回信息，所以要加入多线程
站在用户的角度思考问题，与客户深入沟通，找到夏邑网站设计与夏邑网站推广的解决方案，凭借多年的经验，让设计与互联网技术结合，创造个性化、用户体验好的作品，建站类型包括：成都网站设计、
网站制作、企业官网、英文网站、手机端网站、网站推广、
域名注册、虚拟空间、企业邮箱。业务覆盖夏邑地区。
public class Client {
public static void main(String[]args) throws UnknownHostException, IOException
{
System.out.println("客户端启动中...");
Socket client =new Socket("localhost",9999);
new Thread(new Send(client)).start();
new Thread(new Receive(client)).start();
}
}
客户端的发送端封装了：
发送消息
从键盘读取消息
run()
释放资源
public class Send implements Runnable{
private BufferedReader br;
private DataOutputStream dos;
private Socket client;
private boolean flag=true;
public Send(Socket client)
{
this.client=client;
br=new BufferedReader(new InputStreamReader(System.in));
try {
dos=new DataOutputStream(client.getOutputStream());
} catch (IOException e) {
this.release();
}
}
public void run()
{
while(flag)
{
System.out.println("请输入消息:");
String msg=getstr();
send(msg);
}
}
private void release()
{
this.flag=false;
utils.close(dos,client);
}
//从控制台获取消息
private String getstr()
{
try {
String msg=br.readLine();
return msg;
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
private void send(String msg)
{
try {
dos.writeUTF(msg);
dos.flush();
} catch (IOException e) {
release();
}
}
}
客户端的接收端封装了:
接收消息
run()
释放资源
public class Receive implements Runnable {
private DataInputStream dis;
private Socket client;
private boolean flag=true;
public Receive(Socket client)
{
this.client=client;
try {
dis=new DataInputStream(client.getInputStream());
} catch (IOException e) {
release();
}
}
private String receive()
{
String msg;
try {
msg = dis.readUTF();
return msg;
} catch (IOException e) {
release();
}
return null;
}
public void run()
{
while(flag)
{
String msg=receive();
System.out.println(msg);
}
}
private void release()
{
this.flag=false;
utils.close(dis,client);
}
}
作为释放资源工具类
public class utils {
public static void close(Closeable... target )
{
for(Closeable it:target)
{
try {
if(null!=it)
{
it.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
在线聊天室
服务器：
public class Chat {
public static void main(String[]args) throws IOException
{
System.out.println("服务器启动中...");
ServerSocket server=new ServerSocket(9999);
while(true)
{
Socket client =server.accept();
System.out.println("一个客户端建立了连接");
new Thread(new channel(client)).start();
}
}
static class channel implements Runnable{
private DataInputStream dis;
private DataOutputStream dos;
private BufferedReader br;
private Socket client;
private boolean flag;
public channel(Socket client)
{
this.client=client;
try {
dis=new DataInputStream(client.getInputStream());
dos=new DataOutputStream(client.getOutputStream());
flag=true;
} catch (IOException e) {
release(); }
}
//接收消息
private String receive()
{
try {
String msg=dis.readUTF();
return msg;
} catch (IOException e) {
release();
}
return null;
}
//发送给消息
private void send(String msg)
{
try {
dos.writeUTF(msg);
dos.flush();
} catch (IOException e) {
release();
}
}
private void release()
{
this.flag=false;
utils.close(dis,dos,client); //写一个工具类,使用Closeable...可变参数
}
public void run()
{
while(flag)
{
String msg=receive();
send(msg);
}
release();
}
}
}
另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
网站名称：java网络编程-TCP-多人聊天(面向对象封装)-创新互联
网页路径：
http://www.cdkjz.cn/article/dpjpji.html
