С Новым годом! Форум программистов, компьютерный форум, киберфорум
Java: Сети
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
 Аватар для snajper_ro
116 / 101 / 52
Регистрация: 14.09.2011
Сообщений: 696
Записей в блоге: 1

Java.net.BindException: Address already in use: connect

18.12.2017, 20:05. Показов 1256. Ответов 0
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
После 16 тысячи запросов появляется ошибка
запускается все на локальной машине
клиент
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
import javax.swing.*;
import java.io.*;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.util.Date;
import java.util.Properties;
import java.util.concurrent.atomic.AtomicInteger;
 
public class Client extends JFrame {
 
    private AtomicInteger counter = new AtomicInteger();
    private JLabel label = new JLabel();
    private Date start = new Date();
 
    public Client(int threads, String proxyUrl, int port, String data) {
        this.add(label);
        this.setSize(200, 100);
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
 
        final byte[] bytes = data.getBytes();
 
 
 
        for (int i = 0; i < 20000; i++) {
            try {
                byte[] readBytes = new byte[1024];
                ByteArrayOutputStream result = new ByteArrayOutputStream(bytes.length);
 
                final Socket socket = new Socket();
                socket.setReuseAddress(true);
                socket.connect(new InetSocketAddress(proxyUrl, port));
                OutputStream outputStream = socket.getOutputStream();
                InputStream inputStream = socket.getInputStream();
                outputStream.write(bytes);
                socket.shutdownOutput();
                int size;
                while((size = inputStream.read(readBytes))!= -1){
                    result.write(readBytes,0, size);
                }
                if(result.size() != bytes.length ){
                    System.err.println("problems");
                }
                socket.close();
                setLabelText();
 
            } catch (IOException e) {
                e.printStackTrace();
            }
 
        }
    }
 
    private void setLabelText() {
        counter.incrementAndGet();
        if(counter.get()%100==0) {
            System.out.println("counter = " + counter.get());
            SwingUtilities.invokeLater(new Runnable() {
                @Override
                public void run() {
                    long seconds = (new Date().getTime() - start.getTime()) / 100;
                    if (seconds > 0) {
                        label.setText(counter.get() / seconds + " request/second");
 
                    }
 
                }
            });
        }
    }
 
    public static void main(String[] args) throws IOException {
     
        System.out.println("start client");
        Client client = new Client(2, "127.0.0.1",
                15689, "test data");
        client.setVisible(true);
    }
 
}
server
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Properties;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger;
 
public class Server2 {
    private ExecutorService executorService;
    private AtomicInteger counter = new AtomicInteger();
 
    public Server2(int threads, int runningPort) throws Exception {
        executorService = Executors.newFixedThreadPool(threads);
        ServerSocket serverSocket = new ServerSocket(runningPort);
        serverSocket.setReuseAddress(true);
        while (true) {
            final Socket socket = serverSocket.accept();
 
            new Thread() {
                @Override
                public void run() {
                    InputStream inputStream1 = null;
                    try {
                        inputStream1 = socket.getInputStream();
 
                        OutputStream outputStream1 = socket.getOutputStream();
 
                        byte[] bytes = new byte[8162];
                        int size = 0;
                        while ((size = inputStream1.read(bytes)) != -1) {
                            outputStream1.write(bytes, 0, size);
 
                        }
                        socket.close();
                        if (counter.incrementAndGet() % 100 == 0) {
                            System.out.println(counter.get());
                        }
                    } catch (IOException e1) {
                        e1.printStackTrace();
                    }
                }
 
            }.start();
 
        }
    }
 
    public static void main(String[] args) throws Exception {
        int port = 15689;
        Server2 server2 =
                new Server2(10, port);
    }
}
0
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
18.12.2017, 20:05
Ответы с готовыми решениями:

Java.net.BindException: Address already in use: NET_Bind
Причем я уже на разных портах своего компа сервер создавал - результат один и тот же. Хз почему так, помогите пожалуйста

Netty exceptions (java.net.BindException, Connection reset by peer)
Привет. У меня возникла такая проблема. На клиенте при отправке сообщений с большой нагрузкой возникает java.net.BindException:...

Java.net.ConnectException: Connection timed out: connect
В чем мой косяк, и что мне делать, чтобы его исправить? import javax.swing.*; import java.awt.*; import...

0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
18.12.2017, 20:05
Помогаю со студенческими работами здесь

Connection refused: connect в java.net.Socket
\о Работая над сокетным чатом, столкнулся с такой проблемой: при Socket ss = new Socket(host, port); с SocketServer h = new...

java.net.ConnectException: Connection refused: connect
сервер-клиент,при запуске проги выдается ошибка в консоли приложения: java.net.ConnectException: Connection refused: connect. Кто чем...

Address family not supported by protocol family: connect
Здравствуйте. Не знаю что случилось, но мой Eclipse (luna) перестал импортировать проекты через Gradle и заходить в Eclipse Marketplace....

Error #: 306 : constructor Socket(java.net.SocketImpl) has protected access in class java.net.Socket at line 282, column 32
привет , как сделать чтобы это компилилось а не выдавало ошибок sock = new Socket(cServerIp, nPort, cLocalIp, 0); Error #: 306 :...

Connect to Mongo DB from Java
Такая проблема, нужно подключится к базе Mongo DB c аутентификацией, используя mongo-java-driver-3.4.2. Стандартный код ...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
1
Ответ Создать тему
Новые блоги и статьи
Модель микоризы: классовый агентный подход 3
anaschu 06.01.2026
aa0a7f55b50dd51c5ec569d2d10c54f6/ O1rJuneU_ls https:/ / vkvideo. ru/ video-115721503_456239114
Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR
ФедосеевПавел 06.01.2026
Owen Logic: О недопустимости использования связки «аналоговый ПИД» + RegKZR ВВЕДЕНИЕ Введу сокращения: аналоговый ПИД — ПИД регулятор с управляющим выходом в виде числа в диапазоне от 0% до. . .
Модель микоризы: классовый агентный подход 2
anaschu 06.01.2026
репозиторий https:/ / github. com/ shumilovas/ fungi ветка по-частям. коммит Create переделка под биомассу. txt вход sc, но sm считается внутри мицелия. кстати, обьем тоже должен там считаться. . . .
Расчёт токов в цепи постоянного тока
igorrr37 05.01.2026
/ * Дана цепь постоянного тока с сопротивлениями и напряжениями. Надо найти токи в ветвях. Программа составляет систему уравнений по 1 и 2 законам Кирхгофа и решает её. Последовательность действий:. . .
Новый CodeBlocs. Версия 25.03
palva 04.01.2026
Оказывается, недавно вышла новая версия CodeBlocks за номером 25. 03. Когда-то давно я возился с только что вышедшей тогда версией 20. 03. С тех пор я давно снёс всё с компьютера и забыл. Теперь. . .
Модель микоризы: классовый агентный подход
anaschu 02.01.2026
Раньше это было два гриба и бактерия. Теперь три гриба, растение. И на уровне агентов добавится между грибами или бактериями взаимодействий. До того я пробовал подход через многомерные массивы,. . .
Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост.
Programma_Boinc 28.12.2025
Советы по крайней бережливости. Внимание, это ОЧЕНЬ длинный пост. Налог на собак: https:/ / **********/ gallery/ V06K53e Финансовый отчет в Excel: https:/ / **********/ gallery/ bKBkQFf Пост отсюда. . .
Кто-нибудь знает, где можно бесплатно получить настольный компьютер или ноутбук? США.
Programma_Boinc 26.12.2025
Нашел на реддите интересную статью под названием Anyone know where to get a free Desktop or Laptop? Ниже её машинный перевод. После долгих разбирательств я наконец-то вернула себе. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru