Я использую Калифорнийский API (https://github.com/eclipse/californium) для отправки данных с использованием протокола CoAP.
Ниже приведен фрагмент кода для клиента и сервера.
Сервер:
public class HelloWorldServer extends CoapServer {
/*
* Application entry point.
*/
public static void main(String[] args) {
try {
// create server
HelloWorldServer server = new HelloWorldServer();
server.start();
} catch (SocketException e) {
System.err
.println("Failed to initialize server: " + e.getMessage());
}
}
/*
* Constructor for a new Hello-World server. Here, the resources of the
* server are initialized.
*/
public HelloWorldServer() throws SocketException {
// provide an instance of a Hello-World resource
add(new HelloWorldResource());
}
/*
* Definition of the Hello-World Resource
*/
class HelloWorldResource extends CoapResource {
public HelloWorldResource() {
// set resource identifier
super("helloWorld");
// set display name
getAttributes().setTitle("Hello-World Resource");
}
@Override
public void handleGET(CoapExchange exchange) {
// respond to the request
exchange.respond("Hello World!");
}
@Override
public void handlePOST(CoapExchange exchange){
//System.out.println("Start "+System.currentTimeMillis());
exchange.accept();
//List<String> queries = exchange.getRequestOptions().getURIQueries();
// System.out.println("Text Received : "+ exchange.getRequestText().length());
// System.out.println("End "+System.currentTimeMillis());
exchange.respond("Received");
}
}
}
Код клиента:
try {
long startTime = System.currentTimeMillis();
for (int i = 0; i < 1000000; i++) {
CoapClient client = new CoapClient(new URI("coap://192.168.15.170:5683/helloWorld"));
CoapResponse response = client.post(str, 0);
}
System.out.println("done");
} catch (URISyntaxException e) {
e.printStackTrace();
}catch (Exception e) {
e.printStackTrace();
}
Я отправляю 1000000 записей, но при отправке сначала он отправляет 65535 записей и ждет несколько секунд. После ожидания в течение нескольких секунд он снова начинает отправку.
Сведения о системе:
ОС: Win 7 64 бит. Оперативная память: 4 ГМ
Зачем ждать после 65535 записей?