TCP:模拟登录 :多个客户端,先后等待
创新互联坚持“要么做到,要么别承诺”的工作理念,服务领域包括:成都网站制作、成都网站设计、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的吉林网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!public class tcp {
public static void main(String[]args) throws IOException
{
System.out.println("服务器启动中...");
ServerSocket server=new ServerSocket(8888);
boolean flag=true;
while(flag) {
Socket client=server.accept(); //一个客户端建立连接
System.out.println("一个客户端建立了连接");
new Thread(new channel(client)).start();
}
}
static class channel implements Runnable{
private Socket client;
private DataInputStream dis; //输入流
DataOutputStream dos; //输出流
public channel(Socket client)
{
this.client=client;
try {
dis=new DataInputStream(client.getInputStream());
dos=new DataOutputStream(client.getOutputStream());
} catch (IOException e) {
e.printStackTrace();
release();
}
}
public void run()
{
String uname="";
String password="";
String data=receive();
String[] datas=data.split("&");
uname=datas[0];
password=datas[1];
if(uname.equals("杜雨龙")&&password.equals("你最帅"))
{
send("登陆成功");
}else
{
send("登录失败");
}
release();
}
//接收数据
private String receive()
{
String data="";
try {
data = dis.readUTF();
} catch (IOException e) {
e.printStackTrace();
}
return data;
}
//发送数据
private void send(String msg)
{
try {
dos.writeUTF(msg);
dos.flush();
} catch (IOException e) {
e.printStackTrace();
}
}
//释放资源
private void release()
{
try {
if(null!=dis)
{
dis.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(null!=dis)
{
dos.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(null!=client)
{
client.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
客户端: 存储文件
public class tcp2 {
public static void main(String[]args) throws IOException
{
System.out.println("客户端启动中...");
Socket client=new Socket("localhost",8888);
//发送
new send(client).sendto();
new receive(client).receiveto();
client.close();
}
static class send{
private Socket client;
private DataOutputStream dos;
private BufferedReader br;
private String msg;
public send(Socket client)
{
this.client=client;
br=new BufferedReader(new InputStreamReader(System.in));
msg=init();
try {
dos =new DataOutputStream(client.getOutputStream());
} catch (IOException e) {
e.printStackTrace();
}
}
public void sendto()
{
try {
dos.writeUTF(msg);
dos.flush();
} catch (IOException e) {
e.printStackTrace();
}
}
public String init()
{
try {
System.out.println("请输入用户名");
String name=br.readLine();
System.out.println("请输入密码");
String password=br.readLine();
return name+"&"+password;
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
}
static class receive{
private DataInputStream dis;
private Socket client;
public receive(Socket client)
{
this.client=client;
DataInputStream dis=new DataInputStream(client.getInputStream());
}
public void receiveto()
{
String data;
try {
data = dis.readUTF();
System.out.println(data);
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。