Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.net.Socket;
- import java.net.ServerSocket;
- import java.io.DataInputStream;
- import java.io.BufferedReader;
- import java.io.InputStreamReader;
- public class Server {
- public static void main(String[] args) {
- try {
- System.out.println("Server is running");
- int port = 3333;
- if (args.length > 0) {
- port = new Integer(args[0]);
- }
- // создание серверного сокета
- ServerSocket ss = new ServerSocket(port);
- // Ждет клиентов и для каждого создает отдельный поток
- while (true) {
- Socket s = ss.accept();
- ServerConnectionProcessor p =
- new ServerConnectionProcessor(s);
- p.start();
- }
- }
- catch(Exception e) {
- System.out.println(e);
- }
- }
- }
- class ServerConnectionProcessor extends Thread {
- private Socket sock;
- public ServerConnectionProcessor(Socket s) {
- sock = s;
- }
- public void run() {
- try {
- // Получает запрос
- DataInputStream inStream = new DataInputStream(
- sock.getInputStream());
- BufferedReader d = new BufferedReader(new InputStreamReader(inStream));
- String str = d.readLine();
- System.out.println(str);
- /*int arg1 = inStream.readInt();
- int arg2 = inStream.readInt();
- // Выполняет расчет
- int result = 0;
- if (operationId == 0) {
- result = arg1 + arg2;
- }
- else if (operationId == 1) {
- result = arg1 * arg2;
- }
- // Отправляет ответ
- DataOutputStream outStream = new DataOutputStream(
- sock.getOutputStream());
- outStream.writeInt(result);
- // Подождем немного и завершим поток
- */
- sleep(1000);
- inStream.close();
- //outStream.close();
- sock.close();
- }
- catch(Exception e) {
- System.out.println(e);
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement