JAVA网络编程新手问题 - 黑马程序员技术交流社区

服务端代码
import java.net.*;
import java.io.*;
public class Server1 implements Runnable
{
ServerSocket server = null;
Socket clientSocket;
boolean flag = true; //标记是否结束
Thread c; //向客户器端发送信息的线程
BufferedReader sin;
DataOutputStream sout;
public static void main(String args[])
{
new Server1().ServerStart();
}
public void ServerStart()
{
try
{
server = new ServerSocket(5678);
System.out.println("端口号:"+server.getLocalPort());
while(flag)
{
clientSocket = server.accept();
System.out.println("已建立连接!");
InputStream is = clientSocket.getInputStream();
sin = new BufferedReader(new InputStreamReader(is));
OutputStream os = clientSocket.getOutputStream();
sout = new DataOutputStream(os);
c = new Thread(this);
c.start(); //启动线程，向客户器端发送信息
String aline;
while((aline=sin.readLine())!=null)
{ //接收客户端的数据
System.out.println(aline);
if(aline.equals("bye"))
{
flag = false;
c.interrupt(); //线程中断
break;
}
}
sout.close(); //关闭流
os.close();
sin.close();
is.close();
//clientSocket.close(); //关闭Socket连接
System.exit(0); //程序运行结束
}
}
catch(Exception e)
{
System.out.println(e);
}
}
public void run()
{
while(true)
{
try
{
int ch;
while((ch=System.in.read())!=-1)
{ //从键盘接收字符并向客户端发送
sout.write((byte)ch);
if(ch=='\n')
sout.flush(); //将缓冲区内容向输出流发送
}
}
catch(Exception e)
{
System.out.println(e);
}
}
}
public void finalize() //析构方法
{
try
{
server.close(); //停止ServerSocket服务
}
catch(IOException e)
{
System.out.println(e);
}
}
}

复制代码

客户端代码
import java.net.*;
import java.io.*;
public class Client1 implements Runnable
{
Socket clientSocket;
boolean flag=true; //标记是否结束
Thread c; //用于向服务器端发送信息
BufferedReader cin;
DataOutputStream cout;
public static void main(String arg[])
{
new Client1().ClientStart();
}
public void ClientStart()
{
try
{ //连接服务器端，这里使用本机
clientSocket=new Socket("localhost",5678);
System.out.println("已建立连接!");
while(flag)
{ //获取流对象
InputStream is = clientSocket.getInputStream();
cin=new BufferedReader(new InputStreamReader(is));
OutputStream os = clientSocket.getOutputStream();
cout = new DataOutputStream(os);
c = new Thread(this);
c.start(); //启动线程，向服务器端发送信息
String aline;
while((aline=cin.readLine())!=null)
{ //接收服务器端的数据
System.out.println(aline);
if(aline.equals("bye"))
{
flag = false;
c.interrupt();
break;
}
}
cout.close();
os.close();
cin.close();
is.close();
clientSocket.close(); //关闭Socket连接
System.exit(0);
}
}
catch(Exception e)
{
System.out.println(e);
}
}
public void run()
{
while(true)
{
try
{ //从键盘接收字符并向服务器端发送
int ch;
while((ch=System.in.read())!=-1)
{
cout.write((byte)ch);
if(ch=='\n')
cout.flush(); //将缓冲区内容向输出流发送
}
}
catch(Exception e)
{
System.out.println(e);
}
}
}
}

复制代码