Java多线程Socket操作猜数游戏样例
2008-05-12 19:36
253 查看
1 服务器端程序,接受连接并处理客户端的请求
ServerApp.java
package test;
import java.io.*;
import java.net.*;
/** *//**
* 服务器端程序
*
* @author luxuan310,修正赵学庆。
*
*/
public class ServerApp ...{
static final int PORT = 9000;
private ServerSocket serverSocket;
private Socket socket;
private BufferedReader netIn;
private PrintWriter netOut;
public ServerApp() throws IOException ...{
serverSocket = new ServerSocket(PORT);
System.out.println("server start");
while (true) ...{
// 等待连接
socket = serverSocket.accept();
ServerThread st = new ServerThread(socket);
new Thread(st).start();
}
}
class ServerThread implements Runnable ...{
private Socket socket;
private int randomNumber;
private int clientGuessNumber;
public ServerThread(Socket s) throws IOException ...{
socket = s;
netIn = new BufferedReader(new InputStreamReader(socket.getInputStream()));
netOut = new PrintWriter(socket.getOutputStream());
}
public void run() ...{
System.out.println("client" + socket.getInetAddress() + " is connect");
randomNumber = (int) (Math.random() * 100);
System.out.println("random number is:" + randomNumber);
try ...{
clientGuessNumber = Integer.parseInt(netIn.readLine());
System.out.println("client guess number is:" + clientGuessNumber);
for (int i = 3; i > 0; i--) ...{
if (clientGuessNumber == randomNumber) ...{
netOut.println("OK,恭喜,猜对了");
ClientApp.finished = true;
} else if (clientGuessNumber < randomNumber) ...{
netOut.println("您猜的数小了,您还有" + (i - 1) + "次机会");
ClientApp.finished = false;
} else if (clientGuessNumber > randomNumber) ...{
netOut.println("您猜的数大了,您还有" + (i - 1) + "次机会");
ClientApp.finished = false;
}
netOut.flush();
if (!ClientApp.finished) ...{
clientGuessNumber = Integer.parseInt(netIn.readLine());
} else ...{
break;
}
}
if (!ClientApp.finished) ...{
netOut.println("OK,您没有机会了,游戏结束");
}
ClientApp.finished = true;
} catch (IOException e) ...{
} finally ...{
try ...{
netOut.close();
netIn.close();
socket.close();
} catch (IOException ee) ...{
}
}
}
}
public static void main(String[] args) throws IOException ...{
new ServerApp();
}
}
2 客户端程序,发送每次猜的数字
package test;
import java.io.*;
import java.net.*;
public class ClientApp ...{
private Socket socket;
private BufferedReader netIn;
private PrintWriter netOut;
private BufferedReader keyboardIn;
static Boolean finished = false;
public ClientApp() throws IOException ...{
System.out.println("请输入服务器地址,连接本地服务器请输入localhost");
keyboardIn = new BufferedReader(new InputStreamReader(System.in));
try ...{
if (keyboardIn.readLine().equalsIgnoreCase("localhost")) ...{
socket = new Socket(InetAddress.getLocalHost(), ServerApp.PORT);
} else ...{
socket = new Socket(InetAddress.getByName(keyboardIn.readLine()), ServerApp.PORT);
}
netIn = new BufferedReader(new InputStreamReader(socket.getInputStream()));
netOut = new PrintWriter(socket.getOutputStream());
} catch (UnknownHostException e) ...{
System.err.println("连接不到服务器");
System.exit(-1);
}
System.out.println("连接成功");
while (!finished) ...{
System.out.println("请输入0-100之间的数字");
netOut.println(keyboardIn.readLine());
netOut.flush();
String str = netIn.readLine();
if (str == null) ...{
finished = true;
break;
}
System.out.println(str);
if (str.startsWith("OK")) ...{
finished = true;
break;
}
}
netIn.close();
netOut.close();
keyboardIn.close();
socket.close();
}
public static void main(String[] args) throws IOException ...{
new ClientApp();
}
}
3 运行效果
ServerApp.java
package test;
import java.io.*;
import java.net.*;
/** *//**
* 服务器端程序
*
* @author luxuan310,修正赵学庆。
*
*/
public class ServerApp ...{
static final int PORT = 9000;
private ServerSocket serverSocket;
private Socket socket;
private BufferedReader netIn;
private PrintWriter netOut;
public ServerApp() throws IOException ...{
serverSocket = new ServerSocket(PORT);
System.out.println("server start");
while (true) ...{
// 等待连接
socket = serverSocket.accept();
ServerThread st = new ServerThread(socket);
new Thread(st).start();
}
}
class ServerThread implements Runnable ...{
private Socket socket;
private int randomNumber;
private int clientGuessNumber;
public ServerThread(Socket s) throws IOException ...{
socket = s;
netIn = new BufferedReader(new InputStreamReader(socket.getInputStream()));
netOut = new PrintWriter(socket.getOutputStream());
}
public void run() ...{
System.out.println("client" + socket.getInetAddress() + " is connect");
randomNumber = (int) (Math.random() * 100);
System.out.println("random number is:" + randomNumber);
try ...{
clientGuessNumber = Integer.parseInt(netIn.readLine());
System.out.println("client guess number is:" + clientGuessNumber);
for (int i = 3; i > 0; i--) ...{
if (clientGuessNumber == randomNumber) ...{
netOut.println("OK,恭喜,猜对了");
ClientApp.finished = true;
} else if (clientGuessNumber < randomNumber) ...{
netOut.println("您猜的数小了,您还有" + (i - 1) + "次机会");
ClientApp.finished = false;
} else if (clientGuessNumber > randomNumber) ...{
netOut.println("您猜的数大了,您还有" + (i - 1) + "次机会");
ClientApp.finished = false;
}
netOut.flush();
if (!ClientApp.finished) ...{
clientGuessNumber = Integer.parseInt(netIn.readLine());
} else ...{
break;
}
}
if (!ClientApp.finished) ...{
netOut.println("OK,您没有机会了,游戏结束");
}
ClientApp.finished = true;
} catch (IOException e) ...{
} finally ...{
try ...{
netOut.close();
netIn.close();
socket.close();
} catch (IOException ee) ...{
}
}
}
}
public static void main(String[] args) throws IOException ...{
new ServerApp();
}
}
2 客户端程序,发送每次猜的数字
package test;
import java.io.*;
import java.net.*;
public class ClientApp ...{
private Socket socket;
private BufferedReader netIn;
private PrintWriter netOut;
private BufferedReader keyboardIn;
static Boolean finished = false;
public ClientApp() throws IOException ...{
System.out.println("请输入服务器地址,连接本地服务器请输入localhost");
keyboardIn = new BufferedReader(new InputStreamReader(System.in));
try ...{
if (keyboardIn.readLine().equalsIgnoreCase("localhost")) ...{
socket = new Socket(InetAddress.getLocalHost(), ServerApp.PORT);
} else ...{
socket = new Socket(InetAddress.getByName(keyboardIn.readLine()), ServerApp.PORT);
}
netIn = new BufferedReader(new InputStreamReader(socket.getInputStream()));
netOut = new PrintWriter(socket.getOutputStream());
} catch (UnknownHostException e) ...{
System.err.println("连接不到服务器");
System.exit(-1);
}
System.out.println("连接成功");
while (!finished) ...{
System.out.println("请输入0-100之间的数字");
netOut.println(keyboardIn.readLine());
netOut.flush();
String str = netIn.readLine();
if (str == null) ...{
finished = true;
break;
}
System.out.println(str);
if (str.startsWith("OK")) ...{
finished = true;
break;
}
}
netIn.close();
netOut.close();
keyboardIn.close();
socket.close();
}
public static void main(String[] args) throws IOException ...{
new ClientApp();
}
}
3 运行效果
相关文章推荐
- Java多线程Socket操作猜数游戏样例
- Java多线程Socket操作猜数游戏样例
- Java中文件和文件夹创建、删除和移动操作,Java Socket多线程传输多文件
- JAVA之旅(三十二)——JAVA网络请求,IP地址,TCP/UDP通讯协议概述,Socket,UDP传输,多线程UDP聊天应用
- socket ( java ) 简单多个客户端、服务端通信(多线程)
- Android游戏开发之多线程的操作方式
- java多线程的基本概念和简单操作
- Java Socket 多线程编程及socket协议详解
- java socket 多线程的服务端与客户端的demo
- java操作数据库出现(][SQLServer 2000 Driver for JDBC]Error establishing socket.)的问题所在即解决办法
- java 线程 原子类相关操作演示样例 thinking in java4 文件夹21.3.4
- java多线程简单操作和实际项目开发如何写
- C# 多线程操作样例
- java 网络流 TCP Socket和SeverSocket 上传文件(字节流)+ 服务器多线程
- java多线程系列:通过对战游戏学习CyclicBarrier
- Java Socket应用(二)--多线程服务器
- java课程设计——猜数游戏个人博客
- JAVA课程设计 猜数游戏 团队
- Java入门到精通——基础篇之多线程实现简单的PV操作的进程同步
- java 网络编程(2.2)-----------采用线程池多线程的Socket 通信