Java

cluster-announce-port · Приходите на Java Meeting Point 23 июня, чтобы услышать доклад Дмитрия. Регистрация открыта на

const gulp = require('gulp');

const gulp = require('gulp');const requireDir = require('require-dir');const tasks = requireDir('./tasks');

module.exports = function hello () {console.log("Hello Gulp!");}

const gulp = require('gulp');const requireDir = require('require-dir');const tasks = requireDir('./tasks');exports.hello = tasks.hello;

[13:17:15] Using gulpfile D:\Web projects\Easy-webdev-startpack-new\gulpfile.js[13:17:15] Starting 'hello'...Hello Gulp![13:17:15] The following tasks did not complete: hello[13:17:15] Did you forget to signal async completion?

 project/  build/ 

class LoggerService {  constructor(prefix) {    this.logPrefix = prefix  }  log(...props) {    console.log(new Date().toISOString().substr(0, 19), this.logPrefix, ...props)  }  error(...props) {    console.error(new Date().toISOString().substr(0, 19), this.logPrefix, ...props)  }}

yarn add node-binance-api

class BaseApiService {  constructor({ client, secret }) {    const { log, error } = new Logger('BaseApiService')    this.log = log    this.error = error    this.api = new NodeBinanceApi().options({      APIKEY: client,      APISECRET: secret,      hedgeMode: true,    })    this.exchangeInfo = {}  }  async init() {    try {      this.exchangeInfo = await this.api.futuresExchangeInfo()    } catch (e) {      this.error('init error', e)    }  }  getAssetQuantityPrecision(symbol) {    const { symbols = [] } = this.exchangeInfo    const s = symbols.find(s => s.symbol === symbol) || { quantityPrecision: 3 }    return s.quantityPrecision  }  getAssetPricePrecision(symbol) {    const { symbols = [] } = this.exchangeInfo    const s = symbols.find(s => s.symbol === symbol) || { pricePrecision: 2 }    return s.pricePrecision  }}

async futuresOrder(side, symbol, qty, price, params={}) {  try {    qty = Number(qty).toFixed(this.getAssetQuantityPrecision(symbol))    price = Number(price).toFixed(this.getAssetPricePrecision(symbol))    if (!params.type) {      params.type = ORDER.TYPE.MARKET    }    const res = await this.api.futuresOrder(side, symbol, qty, price || false, params)    this.log('futuresOrder', res)    return res  } catch (e) {    console.log('futuresOrder error', e)  }}

class TradeService {  constructor({client, secret}) {    const { log, error } = new LoggerService('TradeService')    this.log = log    this.error = error    this.api = new NodeBinanceApi().options({      APIKEY: client,      APISECRET: secret,      hedgeMode: true,    })    this.events = new EventEmitter()  }  marginCallCallback = (data) => this.log('marginCallCallback', data)  accountUpdateCallback = (data) => this.log('accountUpdateCallback', data)  orderUpdateCallback = (data) => this.emit(data)  subscribedCallback = (data) => this.log('subscribedCallback', data)  accountConfigUpdateCallback = (data) => this.log('accountConfigUpdateCallback', data)  startListening() {    this.api.websockets.userFutureData(      this.marginCallCallback,      this.accountUpdateCallback,      this.orderUpdateCallback,      this.subscribedCallback,      this.accountConfigUpdateCallback,    )  }  subscribe(cb) {    this.events.on('trade', cb)  }  emit = (data) => {    this.events.emit('trade', data)  }}

yarn add sequelize-cli -Dyarn add sequelizenpx sequelize-cli init

version: '3.1'services:  db:    image: 'postgres:12'    restart: unless-stopped    volumes:      - ./volumes/postgresql/data:/var/lib/postgresql/data    environment:      POSTGRES_USER: root      POSTGRES_PASSWORD: example      POSTGRES_DB: bot    ports:      - 5432:5432    networks:      - postgresnetworks:  postgres:    driver: bridge

/** Правило проверяет лексему на соответствие */typealias Rule = (String) -> Boolean/** Нормализованное семантическое представление */open class Semnorm(vararg val rules: Rule)/** Правило задает стемы для семантических представлений */fun stem(vararg stems: String): Rule = { stems.any(it::startsWith) }/** Правило задает точные соответствия для семантических представлений */fun word(vararg words: String): Rule = { words.any(it::equals) }/** Проверяем слово на соответствие семантике */fun String.matches(norm: Semnorm) = norm.rules.any { it(this) }

object Day : Semnorm(stem("day", "суток", "сутк", "дня", "ден", "дне"))

assertThat(  "забань васю на 5 минут".tokenize(),   equalTo(   listOf(     Token("забань", Ban),      Token("васю", null),     Token("на", null),      Token("5", Number),     Token("минут", Minute)   )  ))

object Help : ExecutableSemnorm(stem(  "помощ", "справк", "правил", "help",   "rule", "faq", "start", "старт",)) {  override fun execute(bot: Botm: Message) {    val faq = message.from.relatedFaq()    bot.sendMessage(m.chat.id, faq)  }}

object Ban : DurableSemonrm(stem(  "ban", "block", "mute", "бан", "блок",  "забан", "завали", "замьют",)) {  override fun execute(    bot: Bot, attackerMessage: Message, duration: Duration) {    val victimMessage = attackerMessage.replyToMessage    val victimId = victimMessage.from.id    val untilSecond = now().epochSecond + duration.inWholeSeconds    bot.restrictChatMember(      attackerMessage.chat.id, victimId, untilSecond)  }}

object Week : Semnorm(stem("week", "недел")) {  override fun toDuration(number: Long) =     days(number) * 7}

class DurableSemnorm(vararg rules: Rule) : ExecutableSemnorm(*rules) {  final override fun execute(    token: Iterator<Token>, bot: Bot, m: Message) =       execute(bot, message, token.parseDuration())  abstract fun execute(bot: Bot, m: Message, duration: Duration)}

    @Test    fun testLevel1() {        val result = Mono.just("")            .map { "123" }            .block()        assertEquals("123", result)    }

    fun nonBlockingMethod1sec(data: String)     = data.toMono().delayElement(Duration.ofMillis(1000))    @Test    fun testLevel2() {        val result = nonBlockingMethod1sec("Hello world")            .flatMap { nonBlockingMethod1sec(it) }            .block()        assertEquals("Hello world", result)    }

    fun collectTasks() = (0..99)    @Test    fun testLevel3() {        val result = nonBlockingMethod1sec("Hello world")            .flatMap { businessContext ->                collectTasks()                    .toFlux()                    .map {                        businessContext + it                    }                    .collectList()            }            .block()!!        assertEquals(collectTasks().toList().size, result.size)    }

    fun collectTasks() = (0..100)        @Test    fun testLevel4() {        val result = nonBlockingMethod1sec("Hello world")            .flatMap { businessContext ->                collectTasks().toFlux()                    .flatMap {                        Mono.deferContextual { reactiveContext ->                            val hash = businessContext + it + reactiveContext["requestId"]                            hash.toMono()                        }                    }.collectList()            }            .contextWrite { it.put("requestId", UUID.randomUUID().toString()) }            .block()!!        assertEquals(collectTasks().toList().size, result.size)    }

    fun collectTasks() = (0..1000)        fun doSomethingNonBlocking(data: String)        = data.toMono().delayElement(Duration.ofMillis(1000))        fun doSomethingBlocking(data: String): String {        Thread.sleep(1000); return data    }    val pool = Schedulers.newBoundedElastic(10, Int.MAX_VALUE, "test-pool")    private val logger = getLogger()    @Test    fun testLevel5() {        val counter = AtomicInteger(0)        val result = nonBlockingMethod1sec("Hello world")            .flatMap { _ ->                collectTasks().toFlux()                    .parallel()                    .runOn(pool)                    .flatMap {                        Mono.deferContextual { _ ->                            doSomethingNonBlocking(it.toString())                                .doOnRequest { logger.info("Added task in pool ${counter.incrementAndGet()}") }                                .doOnNext { logger.info("Non blocking code finished ${counter.get()}") }                                .map { doSomethingBlocking(it) }                                .doOnNext { logger.info("Removed task from pool ${counter.decrementAndGet()}") }                        }                    }.sequential()                    .collectList()            }            .block()!!        assertEquals(collectTasks().toList().size, result.size)    }

        val result = nonBlockingMethod1sec("Hello world")            .flatMap { _ ->                collectTasks().toFlux()                    .parallel(1)                    .runOn(pool, 1)                    .flatMap({                        Mono.deferContextual { _ ->                            doSomethingNonBlocking(it.toString())                        }                    }, false, 1, 1)                    .sequential()                    .collectList()            }            .block()!!

MemoryMXBean memoryMXBean = ManagementFactory.getMemoryMXBean();System.out.println(String.format(Initial memory: %.2f GB,   (double)memoryMXBean.getHeapMemoryUsage().getInit() /1073741824));System.out.println(String.format(Used heap memory: %.2f GB,   (double)memoryMXBean.getHeapMemoryUsage().getUsed() /1073741824));System.out.println(String.format(Max heap memory: %.2f GB,   (double)memoryMXBean.getHeapMemoryUsage().getMax() /1073741824));System.out.println(String.format(Committed memory: %.2f GB,   (double)memoryMXBean.getHeapMemoryUsage().getCommitted() /1073741824));

class Plant {}class Herb extends Plant {}class Shrub extends Plant {}class Climber extends Plant{}class Cucumber extends Climber {}

public class Gardener {   int process(Plant plant) {       if (plant instanceof Cucumber) {           return harvestCucumber();       } else if (plant instanceof Climber) {           return sowClimber();       } else if (plant instanceof Herb) {           return sellHerb();       } else if (plant instanceof Shrub) {           return pruneShrub();       } else {           System.out.println("Unreachable CODE. Unknown Plant type");           return 0;       }   }   private int pruneShrub() { .. }   private int sellHerb() { .. }   private int sowClimber() { .. }   private int harvestCucumber() { .. }}

sealed public class Plant permits Herb, Shrub, Climber {}final class Herb extends Plant {}non-sealed class Shrub extends Plant {}sealed class Climber extends Plant permits Cucumber{}final class Cucumber extends Climber {}

// Этот код не работает в Java 15.// Он будет работать в будущих версиях Java // после реализации type-test-pattern в switch int processInAFutureJavaVersion(Plant plant) {   return switch (plant) {       case Cucumber c -> c.harvestCucumber();       case Climber cl -> cl.sowClimber();       case Herb h -> h.sellHerb();       case Shrub s -> s.pruneShrub();   }}

sealed abstract public class Plant permits Herb, Shrub, Climber {   abstract void grow();}final class Herb extends Plant {   @Override   void grow() {   }}non-sealed abstract class Shrub extends Plant {}sealed class Climber extends Plant permits Cucumber{   @Override   void grow() {   }}final class Cucumber extends Climber {}

sealed public interface Move permits Athlete, Person, Jump, Kick {}final class Athlete implements Move {}record Person(String name, int age) implements Move {}non-sealed interface Jump extends Move {}sealed interface Kick extends Move permits Karate {}final class Karate implements Kick {}

List<String> getTopPerformingStocks(List<Stock> allStocks, LocalDate date) {   // TopStock - локальная запись (Record)   record TopStock(Stock stock, double stockValue) {}   return allStocks.stream()              .map(s -> new TopStock(s, getStockValue(s, date)))              .sorted((s1, s2) -> Double.compare(s1.stockValue(), s2.stockValue()))              .limit(2)              .map(s -> s.stock.getName())              .collect(Collectors.toList());}

public void createLocalInterface() {   interface LocalInterface {       void aMethod();   }   // Код, использующий LocalInterface}public void createLocalEnum() {   enum Color {RED, YELLOW, BLUE}   // Код, использующий enum Color}

void test(int input) {   enum Data {       FOO(input), BAR(input*2); // Ошибка. Нельзя обращаться к input       private final int i;       Data(int i) {           this.i = i;       }   }}

struct signal_buffer {    size_t len;    uint8_t data[];};

int signal_constant_memcmp(const void *s1, const void *s2, size_t n){    size_t i;    const unsigned char *c1 = (const unsigned char *) s1;    const unsigned char *c2 = (const unsigned char *) s2;    unsigned char result = 0;    for (i = 0; i < n; i++) {        result |= c1[i] ^ c2[i];    }    return result;}

from saw_client.llvm import *class ConstantMemcmpEqualSpec(Contract):    def specification(self) -> None:        _1        self.execute_func(_2)        _3

class ConstantMemcmpEqualSpec(Contract):    n: int    def __init__(self, n: int):        super().__init__()        self.n = n    def specification(self) -> None:        s1  = self.fresh_var(array_ty(self.n, i8), "s1")        s1p = self.alloc(array_ty(self.n, i8), points_to = s1)        s2  = self.fresh_var(array_ty(self.n, i8), "s2")        s2p = self.alloc(array_ty(self.n, i8), points_to = s2)        self.precondition(cryptol(f"{s1.name()} == {s2.name()}"))        self.execute_func(s1p, s2p, cryptol(f"{self.n} : [64]"))        self.returns(cryptol("0 : [32]"))

mod = llvm_load_module("libsignal-protocol-c.bc") # An LLVM bitcode filearray_len = 42 # Pick whichever length you want to checkllvm_verify(mod, "signal_constant_memcmp", ConstantMemcmpEqualSpec(array_len))

Verified: lemma_ConstantMemcmpEqualSpec (defined at signal_protocol.py:122)

def ptr_to_fresh(spec: Contract, ty: LLVMType,                 name: str) -> Tuple[FreshVar, SetupVal]:    var = spec.fresh_var(ty, name)    ptr = spec.alloc(ty, points_to = var)    return (var, ptr)class ConstantMemcmpEqualSpec(Contract):    ...    def specification(self) -> None:        (s1, s1p) = ptr_to_fresh(self, array_ty(self.n, i8), "s1")        (s2, s2p) = ptr_to_fresh(self, array_ty(self.n, i8), "s2")        ...

hmac_init : {n} [n][8] -> HMACContexthmac_init = undefinedhmac_update : {n} [n][8] -> HMACContext -> HMACContexthmac_update = undefinedhmac_final : HMACContext -> [SIGNAL_MESSAGE_MAC_LENGTH][8]hmac_final = undefined

class SignalHmacSha256InitSpec(Contract):    key_len: int    def specification(self) -> None:        hmac_context_ptr = self.alloc(...)        (key_data, key)  = ptr_to_fresh(self, array_ty(self.key_len, i8),                                        "key_data")            self.execute_func(..., hmac_context_ptr, key,                          cryptol(f"{self.key_len} : [64]"))        init = f"hmac_init`{{ {self.key_len} }} {key_data.name()}"        dummy_hmac_context = self.alloc(..., points_to = cryptol(init))        self.points_to(hmac_context_ptr, dummy_hmac_context)        self.returns(cryptol("0 : [32]"))key_len = 32init_spec = llvm_assume(mod, "signal_hmac_sha256_init",                        SignalHmacSha256InitSpec(key_len))

def mk_hmac(serialized_len: int, serialized_data: FreshVar,        receiver_identity_key_data : FreshVar,        sender_identity_key_data: FreshVar,        mac_key_len: int, mac_key_data: FreshVar) -> SetupVal:    sender_identity_buf = f"""        [{DJB_TYPE}] # {sender_identity_key_data.name()}            : [{DJB_KEY_LEN} + 1][8]        """    receiver_identity_buf = f"""        [{DJB_TYPE}] # {receiver_identity_key_data.name()}            : [{DJB_KEY_LEN} + 1][8]        """    hmac = f"""        hmac_final         (hmac_update`{{ {serialized_len} }} {serialized_data.name()}          (hmac_update`{{ {DJB_KEY_LEN}+1 }} ({receiver_identity_buf})           (hmac_update`{{ {DJB_KEY_LEN}+1 }} ({sender_identity_buf})            (hmac_init`{{ {mac_key_len} }} {mac_key_data.name()}))))        """    return cryptol(hmac)

lass SignalMessageVerifyMacSpec(Contract):    serialized_len: int    def specification(self) -> None:        ...        mac_index = 8 + self.serialized_len - SIGNAL_MESSAGE_MAC_LENGTH        ser_len   = f"{self.serialized_len} : [64]"        self.points_to(serialized[0], cryptol(ser_len))        self.points_to(serialized[8], serialized_message_data)        self.points_to(serialized[mac_index], mk_hmac(...))        self.execute_func(...)        self.returns(cryptol("1 : [32]"))

uninterps = ["hmac_init", "hmac_update", "hmac_final"]llvm_verify(mod, "signal_message_verify_mac",  SignalMessageVerifyMacSpec(...),            lemmas=[init_spec, update_spec1, update_spec2, final_spec],            script=ProofScript([z3(uninterps)]))

public BigDecimal getOrderPrice(Long orderId) {    List<OrderLine> lines = orderRepository.findByOrderId(orderId);    BigDecimal price = BigDecimal.ZERO;           for (OrderLine line : lines) {        price = price.add(line.getPrice());       }    return price;}

public BigDecimal getOrderPrice(Long orderId) {    List<OrderLine> lines = orderRepository.findByOrderId(orderId);    return lines.stream()                .map(OrderLine::getPrice)                .reduce(BigDecimal.ZERO, BigDecimal::add);}

public BigDecimal getOrderPrice(Long orderId) {    if (orderId == null) {        throw new IllegalArgumentException("Order ID cannot be null");    }    List<OrderLine> lines = orderRepository.findByOrderId(orderId);    return lines.stream()                .map(OrderLine::getPrice)                .reduce(BigDecimal.ZERO, BigDecimal::add);}

public BigDecimal getOrderPrice(Long orderId) {    return Optional.ofNullable(orderId)                                        .map(orderRepository::findByOrderId)                               .flatMap(lines -> {                                                    BigDecimal sum = lines.stream()                        .map(OrderLine::getPrice)                        .reduce(BigDecimal.ZERO, BigDecimal::add);                return Optional.of(sum);                                       }).orElse(BigDecimal.ZERO);                            }

public BigDecimal getOrderPrice(Long orderId) {    return Optional.ofNullable(orderId)            .stream()            .map(orderRepository::findByOrderId)            .flatMap(Collection::stream)            .map(OrderLine::getPrice)            .reduce(BigDecimal.ZERO, BigDecimal::add);}

class Range {private final int low;private final int high;public Range(int low, int high) {this.low = low;this.high = high;}public int getLow() {return low;}public int getHigh() {return high;}@Overridepublic boolean equals(Object o) {if (this == o)return true;if (o == null || getClass() != o.getClass())return false;Range range = (Range) o;return low == range.low &&high == range.high;}@Overridepublic int hashCode() {return Objects.hash(low, high);}@Overridepublic String toString() {return "[" + low + "; " + high + "]";}}

//          это компоненты записи (components)record Range (int low, int hight) { }

@Dataclass Range {private final int low;private final int high;}

data class Range(val low: Int, val high: Int)

class Pair {private final int first;private final int second;}

// given: bijective function from int to intIntUnaryOperator increment =i -> i == Integer.MAX_VALUE ? Integer.MIN_VALUE : ++i;// then: combining two `increment`s yields a bijective function//       (this requires no additional proof or consideration)UnaryOperator<Pair> incrementPair =pair -> new Pair(increment.applyAsInt(pair.first()),increment.applyAsInt(pair.second()));

if (range instanceof Range(int low, int high) && high < low)    return new Range(high, low);

Range range = new Range(5, 10);// SYNTAX IS MADE UP!Range newRange = range with { low = 0; }// range: [5; 10]// newRange: [0; 10]

Unable to connect to [172.17.0.3/<unresolved>:7003]: connection timed out: /172.17.0.3:7003

public SocketAddress resolve(RedisURI redisURI) {    Integer mappedPort = redisClusterNatPortMapping.get(redisURI.getPort());    if (mappedPort != null) {        SocketAddress socketAddress = redisClusterSocketAddresses.get(mappedPort);        if (socketAddress != null) {            return socketAddress;        }        redisURI.setPort(mappedPort);    }    redisURI.setHost(DockerClientFactory.instance().dockerHostIpAddress());    SocketAddress socketAddress = super.resolve(redisURI);    redisClusterSocketAddresses.putIfAbsent(redisURI.getPort(), socketAddress);    return socketAddress;}

String result = l.lock(new ArrayList<Locker.Item>() {{    add(new Locker.Item(SimpleType.TRIP, 1));    add(new Locker.Item(SimpleType.USER, 2));}}, () -> {    // Тут выполняем отмену поездки и держим водителя на привязи    // Кстати если кто-то где-то вызовет USER=2 (водитель), то он также будет ждать    // ну или кто-то обратится к поездке TRIP=1    // А если обратится к USER=3, то уже все будет нормально :)    // так как никто не блокировал третьего пользователя :)    return "Тут любой результат :)";    });

<dependencies>    <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-actuator</artifactId>    </dependency></dependencies>

dependencies {    implementation 'org.springframework.boot:spring-boot-starter-actuator'}

$ curl http://localhost:8080/actuator/health{"status":"UP"}

$ curl http://localhost:8080/actuator{"_links":{"self":{"href":"http://localhost:8080/actuator","templated":false},"health":{"href":"http://localhost:8080/actuator/health","templated":false},"health-path":{"href":"http://localhost:8080/actuator/health/{*path}","templated":true},"info":{"href":"http://localhost:8080/actuator/info","templated":false}}}

management.endpoint.metrics.enabled=false

$ curl http://localhost:8080/actuator/metrics{"timestamp":"2021-04-24T12:55:40.688+00:00","status":404,"error":"Not Found","message":"","path":"/actuator/metrics"}

management.endpoints.web.exposure.include=metrics

{  "students": [    {      "name": "John",      "age": 10,      "grade": 3,      "subjects": ["math", "english"]          },    {      "name": "Jack",      "age": 10,      "grade": 3,      "subjects": ["math", "social science", "painting"]    },    {      "name": "James",      "age": 11,      "grade": 5,      "subjects": ["math", "environmental science", "english"]    },    .... other student objects omitted ...  ]}

$ cat sample.json | jq '.students[] | .name'"John""Jack""James"

$ cat sample.json | jq '.students[] | select(.subjects[] | contains("science"))'{  "name": "Jack",  "age": 10,  "grade": 3,  "subjects": [    "math",    "social science",    "painting"  ]}{  "name": "James",  "age": 11,  "grade": 5,  "subjects": [    "math",    "environmental science",    "english"  ]}

$ cat sample.json | jq '[.students[] | select(.subjects[] | contains("science"))]'[  {    "name": "Jack",    "age": 10,    "grade": 3,    "subjects": [      "math",      "social science",      "painting"    ]  },  {    "name": "James",    "age": 11,    "grade": 5,    "subjects": [      "math",      "environmental science",      "english"    ]  }]

$ cat sample.json | jq '[.students[] | {"studentName": .name, "favoriteSubject": .subjects[0]}]'[  {    "studentName": "John",    "favoriteSubject": "math"  },  {    "studentName": "Jack",    "favoriteSubject": "math"  },  {    "studentName": "James",    "favoriteSubject": "math"  }]

management.endpoints.web.exposure.include=mappings,beans,startup,env,scheduledtasks,caches,metrics

$ curl http://localhost:8080/actuator/mappings | jq

{  "contexts": {    "application": {      "mappings": {        "dispatcherServlets": {          "dispatcherServlet": [            {              "handler": "Actuator web endpoint 'metrics'",              "predicate": "{GET [/actuator/metrics], produces [application/vnd.spring-boot.actuator.v3+json || application/vnd.spring-boot.actuator.v2+json || application/json]}",              "details": {                "handlerMethod": {                  "className": "org.springframework.boot.actuate.endpoint.web.servlet.AbstractWebMvcEndpointHandlerMapping.OperationHandler",                  "name": "handle",                  "descriptor": "(Ljavax/servlet/http/HttpServletRequest;Ljava/util/Map;)Ljava/lang/Object;"                },                "requestMappingConditions": {                  ... properties omitted ...                  ],                  "params": [],                  "patterns": [                    "/actuator/metrics"                  ],                  "produces": [                    ... properties omitted ...                  ]                }              }            },          ... 20+ more handlers omitted ...          ]        },        "servletFilters": [          {            "servletNameMappings": [],            "urlPatternMappings": [              "/*"            ],            "name": "webMvcMetricsFilter",            "className": "org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter"          },          ... other filters omitted ...        ],        "servlets": [          {            "mappings": [              "/"            ],            "name": "dispatcherServlet",            "className": "org.springframework.web.servlet.DispatcherServlet"          }        ]      },      "parentId": null    }  }}

$ curl http://localhost:8080/actuator/mappings | jq '.contexts.application.mappings.dispatcherServlets.dispatcherServlet[] | select(.handler | contains("io.reflectoring.springboot.actuator"))'{  "handler": "io.reflectoring.springboot.actuator.controllers.PaymentController#processPayments(String, PaymentRequest)",  "predicate": "{POST [/{orderId}/payment]}",  "details": {    "handlerMethod": {      "className": "io.reflectoring.springboot.actuator.controllers.PaymentController",      "name": "processPayments",      "descriptor": "(Ljava/lang/String;Lio/reflectoring/springboot/actuator/model/PaymentRequest;)Lio/reflectoring/springboot/actuator/model/PaymentResponse;"    },    "requestMappingConditions": {      "consumes": [],      "headers": [],      "methods": [        "POST"      ],      "params": [],      "patterns": [        "/{orderId}/payment"      ],      "produces": []    }  }}{  "handler": "io.reflectoring.springboot.actuator.controllers.OrderController#getOrders(String)",  "predicate": "{GET [/{customerId}/orders]}",  "details": {    "handlerMethod": {      "className": "io.reflectoring.springboot.actuator.controllers.OrderController",      "name": "getOrders",      "descriptor": "(Ljava/lang/String;)Ljava/util/List;"    },    "requestMappingConditions": {      "consumes": [],      "headers": [],      "methods": [        "GET"      ],      "params": [],      "patterns": [        "/{customerId}/orders"      ],      "produces": []    }  }}{  "handler": "io.reflectoring.springboot.actuator.controllers.OrderController#placeOrder(String, Order)",  "predicate": "{POST [/{customerId}/orders]}",  "details": {    "handlerMethod": {      "className": "io.reflectoring.springboot.actuator.controllers.OrderController",      "name": "placeOrder",      "descriptor": "(Ljava/lang/String;Lio/reflectoring/springboot/actuator/model/Order;)Lio/reflectoring/springboot/actuator/model/OrderCreatedResponse;"    },    "requestMappingConditions": {      "consumes": [],      "headers": [],      "methods": [        "POST"      ],      "params": [],      "patterns": [        "/{customerId}/orders"      ],      "produces": []    }  }}

$ curl http://localhost:8080/actuator/mappings | jq '.contexts.application.mappings.servletFilters'[  {    "servletNameMappings": [],    "urlPatternMappings": [      "/*"    ],    "name": "webMvcMetricsFilter",    "className": "org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter"  },  ... other filters omitted ...]

$ curl http://localhost:8080/actuator/beans | jq{  "contexts": {    "application": {      "beans": {        "endpointCachingOperationInvokerAdvisor": {          "aliases": [],          "scope": "singleton",          "type": "org.springframework.boot.actuate.endpoint.invoker.cache.CachingOperationInvokerAdvisor",          "resource": "class path resource [org/springframework/boot/actuate/autoconfigure/endpoint/EndpointAutoConfiguration.class]",          "dependencies": [            "org.springframework.boot.actuate.autoconfigure.endpoint.EndpointAutoConfiguration",            "environment"          ]        },               .... other beans omitted ...    }  }}

$ curl http://localhost:8080/actuator/beans | jq '.contexts.application.beans | with_entries(select(.value.type | contains("io.reflectoring.springboot.actuator")))'{  "orderController": {    "aliases": [],    "scope": "singleton",    "type": "io.reflectoring.springboot.actuator.controllers.OrderController",    "resource": "file [/code-examples/spring-boot/spring-boot-actuator/target/classes/io/reflectoring/springboot/actuator/controllers/OrderController.class]",    "dependencies": [      "orderService",      "simpleMeterRegistry"    ]  },  "orderService": {    "aliases": [],    "scope": "singleton",    "type": "io.reflectoring.springboot.actuator.services.OrderService",    "resource": "file [/code-examples/spring-boot/spring-boot-actuator/target/classes/io/reflectoring/springboot/actuator/services/OrderService.class]",    "dependencies": [      "orderRepository"    ]  },  ... other beans omitted ...  "cleanUpAbandonedBaskets": {    "aliases": [],    "scope": "singleton",    "type": "io.reflectoring.springboot.actuator.services.tasks.CleanUpAbandonedBaskets",    "resource": "file [/code-examples/spring-boot/spring-boot-actuator/target/classes/io/reflectoring/springboot/actuator/services/tasks/CleanUpAbandonedBaskets.class]",    "dependencies": []  }}

SpringApplication app = new SpringApplication(DemoApplication.class);app.setApplicationStartup(new BufferingApplicationStartup(2048));app.run(args);

$ curl -XPOST 'http://localhost:8080/actuator/startup' | jq{  "springBootVersion": "2.4.4",  "timeline": {    "startTime": "2021-04-24T12:58:06.947320Z",    "events": [      {        "startupStep": {          "name": "spring.boot.application.starting",          "id": 1,          "parentId": 0,          "tags": [            {              "key": "mainApplicationClass",              "value": "io.reflectoring.springboot.actuator.DemoApplication"            }          ]        },        "startTime": "2021-04-24T12:58:06.956665337Z",        "endTime": "2021-04-24T12:58:06.998894390Z",        "duration": "PT0.042229053S"      },      {        "startupStep": {          "name": "spring.boot.application.environment-prepared",          "id": 2,          "parentId": 0,          "tags": []        },        "startTime": "2021-04-24T12:58:07.114646769Z",        "endTime": "2021-04-24T12:58:07.324207009Z",        "duration": "PT0.20956024S"      },         .... other steps omitted ....      {        "startupStep": {          "name": "spring.boot.application.started",          "id": 277,          "parentId": 0,          "tags": []        },        "startTime": "2021-04-24T12:58:11.169267550Z",        "endTime": "2021-04-24T12:58:11.212604248Z",        "duration": "PT0.043336698S"      },      {        "startupStep": {          "name": "spring.boot.application.running",          "id": 278,          "parentId": 0,          "tags": []        },        "startTime": "2021-04-24T12:58:11.213585420Z",        "endTime": "2021-04-24T12:58:11.214002336Z",        "duration": "PT0.000416916S"      }    ]  }}

$ curl -XPOST 'http://localhost:8080/actuator/startup' | jq '.timeline.events | sort_by(.duration) | reverse[] | select(.startupStep.name | contains("instantiate"))'$ 

$ curl -XPOST 'http://localhost:8080/actuator/startup' | jq '[.timeline.events | sort_by(.duration) | reverse[] | select(.startupStep.name | contains("instantiate")) | {beanName: .startupStep.tags[0].value, duration: .duration}]' [  {    "beanName": "orderController",    "duration": "PT1.010878035S"  },  {    "beanName": "orderService",    "duration": "PT1.005529559S"  },  {    "beanName": "requestMappingHandlerAdapter",    "duration": "PT0.11549366S"  },  {    "beanName": "tomcatServletWebServerFactory",    "duration": "PT0.108340094S"  },  ... other beans omitted ...]

jq '[.timeline.events \  | sort_by(.duration) \  | reverse[] \  | select(.startupStep.name \  | contains("instantiate")) \  | {beanName: .startupStep.tags[0].value, duration: .duration}]'

$ curl http://localhost:8080/actuator/env | jq{  "activeProfiles": [],  "propertySources": [    {      "name": "server.ports",      "properties": {        "local.server.port": {          "value": 8080        }      }    },    {      "name": "servletContextInitParams",      "properties": {}    },    {      "name": "systemProperties",      "properties": {        "gopherProxySet": {          "value": "false"        },        "java.class.path": {          "value": "/target/test-classes:/target/classes:/Users/reflectoring/.m2/repository/org/springframework/boot/spring-boot-starter-actuator/2.4.4/spring-boot-starter-actuator-2.4.4.jar:/Users/reflectoring/.m2/repository/org/springframework/boot/spring-boot-starter/2.4.4/spring-boot-starter-2.4.4.jar: ... other jars omitted ... "        },       ... other properties omitted ...      }    },    {      "name": "systemEnvironment",      "properties": {        "USER": {          "value": "reflectoring",          "origin": "System Environment Property \"USER\""        },        "HOME": {          "value": "/Users/reflectoring",          "origin": "System Environment Property \"HOME\""        }        ... other environment variables omitted ...      }    },    {      "name": "Config resource 'class path resource [application.properties]' via location 'optional:classpath:/'",      "properties": {        "management.endpoint.logfile.enabled": {          "value": "true",          "origin": "class path resource [application.properties] - 2:37"        },        "management.endpoints.web.exposure.include": {          "value": "metrics,beans,mappings,startup,env, info,loggers",          "origin": "class path resource [application.properties] - 5:43"        }      }    }  ]}

$ curl http://localhost:8080/actuator/scheduledtasks | jq{  "cron": [    {      "runnable": {        "target": "io.reflectoring.springboot.actuator.services.tasks.ReportGenerator.generateReports"      },      "expression": "0 0 12 * * *"    }  ],  "fixedDelay": [    {      "runnable": {        "target": "io.reflectoring.springboot.actuator.services.tasks.CleanUpAbandonedBaskets.process"      },      "initialDelay": 0,      "interval": 900000    }  ],  "fixedRate": [],  "custom": []}

$ curl http://localhost:8080/actuator/caches | jq{  "cacheManagers": {    "cacheManager": {      "caches": {        "states": {          "target": "java.util.concurrent.ConcurrentHashMap"        },        "shippingPrice": {          "target": "java.util.concurrent.ConcurrentHashMap"        }      }    }  }}

$ curl http://localhost:8080/actuator/health{"status":"UP"}

$ curl http://localhost:8080/actuator/metrics | jq{  "names": [    "http.server.requests",    "jvm.buffer.count",    "jvm.buffer.memory.used",    "jvm.buffer.total.capacity",    "jvm.threads.states",    "logback.events",    "orders.placed.counter",    "process.cpu.usage",    ... other metrics omitted ...  ]}

$ curl http://localhost:8080/actuator/metrics/jvm.memory.used | jq{  "name": "jvm.memory.used",  "description": "The amount of used memory",  "baseUnit": "bytes",  "measurements": [    {      "statistic": "VALUE",      "value": 148044128    }  ],  "availableTags": [    {      "tag": "area",      "values": [        "heap",        "nonheap"      ]    },    {      "tag": "id",      "values": [        "CodeHeap 'profiled nmethods'",        "G1 Old Gen",                ... other tags omitted ...      ]    }  ]}

package tutorials.testproject;import io.github.bonigarcia.wdm.WebDriverManager;import org.openqa.selenium.WebDriver;import org.openqa.selenium.chrome.ChromeDriver;import org.openqa.selenium.edge.EdgeDriver;import org.openqa.selenium.firefox.FirefoxDriver;import org.testng.annotations.Parameters;import org.testng.annotations.Test;public class CrossBrowserTesting {  WebDriver driver;  @Test  @Parameters ( {"BrowserType"} )  public void testExamplePageOnMultipleBrowsers (String browserType) {    if (browserType.equalsIgnoreCase("Chrome")) {      WebDriverManager.chromedriver().setup();      driver = new ChromeDriver();    }    else if (browserType.equalsIgnoreCase("Edge")) {      WebDriverManager.edgedriver().setup();      driver = new EdgeDriver();    }    else if (browserType.equalsIgnoreCase("Firefox")) {      WebDriverManager.firefoxdriver().setup();      driver = new FirefoxDriver();    }    driver.manage().window().maximize();    driver.get("https://example.testproject.io/web/index.html");    System.out.println(browserType + ": " + driver.getTitle());  }}

package tutorials.testproject;import io.github.bonigarcia.wdm.WebDriverManager;import org.openqa.selenium.WebDriver;import org.openqa.selenium.chrome.ChromeDriver;import org.openqa.selenium.edge.EdgeDriver;import org.openqa.selenium.firefox.FirefoxDriver;import org.testng.annotations.Test;public class IndividualBrowserTesting {  WebDriver driver;  @Test  public void testExamplePageOnMultipleBrowsersOnChrome () {    WebDriverManager.chromedriver().setup();    driver = new ChromeDriver();    driver.manage().window().maximize();    driver.get("https://example.testproject.io/web/index.html");    System.out.println("Chrome: " + driver.getTitle());  }  @Test  public void testExamplePageOnMultipleBrowsersOnFirefox () {    WebDriverManager.firefoxdriver().setup();    driver = new FirefoxDriver();    driver.manage().window().maximize();    driver.get("https://example.testproject.io/web/index.html");    System.out.println("Chrome: " + driver.getTitle());  }  @Test  public void testExamplePageOnMultipleBrowsersOnEdge () {    WebDriverManager.edgedriver().setup();    driver = new EdgeDriver();    driver.manage().window().maximize();    driver.get("https://example.testproject.io/web/index.html");    System.out.println("Chrome: " + driver.getTitle());  }}

<suite name="Cross Browser Testing">    <test name = "Test On Chrome">        <parameter name = "BrowserType" value="Chrome"/>            <classes>                <class name = "tutorials.testproject.CrossBrowserTesting"/>            </classes>    </test>    <test name = "Test On Edge">        <parameter name = "BrowserType" value="Edge"/>        <classes>            <class name = "tutorials.testproject.CrossBrowserTesting"/>        </classes>    </test>    <test name = "Test On Firefox">        <parameter name = "BrowserType" value="Firefox"/>        <classes>            <class name = "tutorials.testproject.CrossBrowserTesting"/>        </classes>    </test></suite>

package tutorials.testproject;import io.github.bonigarcia.wdm.WebDriverManager;import org.openqa.selenium.WebDriver;import org.openqa.selenium.chrome.ChromeDriver;import org.openqa.selenium.edge.EdgeDriver;import org.openqa.selenium.firefox.FirefoxDriver;import org.testng.annotations.Parameters;import org.testng.annotations.Test;public class CrossBrowserTesting {  WebDriver driver;  @Test  @Parameters ( {"BrowserType"} )  public void testExamplePageOnMultipleBrowsers (String browserType) {    if (browserType.equalsIgnoreCase("Chrome")) {      WebDriverManager.chromedriver().setup();      driver = new ChromeDriver();    }    else if (browserType.equalsIgnoreCase("Edge")) {      WebDriverManager.edgedriver().setup();      driver = new EdgeDriver();    }    else if (browserType.equalsIgnoreCase("Firefox")) {      WebDriverManager.firefoxdriver().setup();      driver = new FirefoxDriver();    }    driver.manage().window().maximize();    driver.get("https://example.testproject.io/web/index.html");    System.out.println(browserType + ": " + driver.getTitle());  }}

<dependency>     <groupId>io.testproject</groupId>     <artifactId>java-sdk</artifactId>     <version>0.65.0-RELEASE</version> </dependency>

implementation 'io.testproject:java-sdk:0.65.0-RELEASE'

import io.testproject.sdk.drivers.web.ChromeDriver;import io.testproject.sdk.drivers.web.FirefoxDriver;import io.testproject.sdk.drivers.web.EdgeDriver;

public class Main {public static void main(String[] args) {  //your code will be here}}

public class Main {    static Scanner scanner = new Scanner(System.in);    public static void main(String[] args) {        System.out.println("Player 1, please, input your name");        String player1Name = scanner.nextLine();        System.out.println("Hello, " + player1Name + "!");        System.out.println("Player 2, please, input your name");        String player2Name = scanner.nextLine();        System.out.println("Hello, " + player2Name + "!");    }}

Player 1, please, input your nameEgorHello, Egor!Player 2, please, input your nameMaxHello, Max!

public class Main {static final int FILED_LENGTH = 10;    static Scanner scanner = new Scanner(System.in);public static void main(String[] args) {    System.out.println("Player 1, please, input your name");    String player1Name = scanner.nextLine();    System.out.println("Hello, " + player1Name + "!");    System.out.println("Player 2, please, input your name");    String player2Name = scanner.nextLine();    System.out.println("Hello, " + player2Name + "!");        char[][] playerField1 = new char[FILED_LENGTH][FILED_LENGTH];    char[][] playerField2 = new char[FILED_LENGTH][FILED_LENGTH];    char[][] playerBattleField1 = new char[FILED_LENGTH][FILED_LENGTH];    char[][] playerBattleField2 = new char[FILED_LENGTH][FILED_LENGTH];}}

public class Main {    static final int FILED_LENGTH = 10;    static Scanner scanner = new Scanner(System.in);    public static void main(String[] args) {        System.out.println("Player 1, please, input your name");        String player1Name = scanner.nextLine();        System.out.println("Hello, " + player1Name + "!");        System.out.println("Player 2, please, input your name");        String player2Name = scanner.nextLine();        System.out.println("Hello, " + player2Name + "!");        char[][] playerField1 = new char[FILED_LENGTH][FILED_LENGTH];        char[][] playerField2 = new char[FILED_LENGTH][FILED_LENGTH];        fillPlayerField(playerField1);        fillPlayerField(playerField2);    }}private static void fillPlayerField(char[][] playerField) {// your code will be here}

Расставляем 4-палубный корабль. Осталось расставить: 1Input x coord: 1Input y coord: 11. Horizontal; 2. Vertical ?1

private static void fillPlayerField(char[][] playerField) {    // your code will be here}

private static void fillPlayerField(char[][] playerField) {// i - счётчик количества палуб у корабля    // начинаем расстановку с корабля, которого 4 палубы, а заканчиваем кораблями с одной палубой    for (int i = 4; i >= 1; i--) {      // см. подробнее о коде под этой вставкой    for (int k = i; k <= 5 - i; k++) {          System.out.println("Расставляем " + i + "-палубный корабль. Осталось расставить: " + (q + 1));        // some your code here        }    }}

int[][] shipTypeAmount = {{1, 4}, {2, 3}, {3, 2}, {4, 1}};

private static void fillPlayerField(char[][] playerField) {        for (int i = 4; i >= 1; i--) {            // растановка самих кораблей            for (int k = i; k <= 5 - i; k++) {                System.out.println("Расставляем " + i + "-палубный корабль. Осталось расставить: " + (q + 1));                System.out.println("Input x coord: ");                x = scanner.nextInt();                System.out.println("Input y coord: ");                y = scanner.nextInt();                System.out.println("1 - horizontal; 2 - vertical ?");                position = scanner.nextInt();                // если корабль располагаем горизонтально              if (position == 1) {                    // заполняем '1' столько клеток по горизонтали, сколько палуб у корабля                    for (int q = 0; q < i; q++) {                        playerField[y][x + q] = '1';                    }                }                            // если корабль располагаем вертикально                if (position == 2) {                  // заполняем столько клеток по вертикали, сколько палуб у корабля                    for (int m = 0; m < i; m++) {                        playerField[y + m][x] = '1';                    }                }              // печатаем в консоли поле игрока, на котором будет видно, где игрок уже поставил корабли              // о реализации метода - см. ниже                printField(playerField);            }        }    }

static void printField(char[][] field) {        for (char[] cells : monitor) {            for (char cell : t) {              // если значение дефолтовое (в случае char - 0), значит в данной клетке              // корабль не установлен - печатаем пустую клетку                if (cell == 0) {                    System.out.print(" |");                } else {   // если клетка непустая (значение отличается от дефолтового),                  //тогда отрисовываем сожержимое клетки (элемента массива)                    System.out.print(cell + "|");                }            }            System.out.println("");            System.out.println("--------------------");        }    }

 | | | | | | | | | |-------------------- |1|1|1|1| | | | | |-------------------- | | | | | | | | | |-------------------- | | | | | | | | | |-------------------- | | | | | | | | | |-------------------- | | | | | | | | | |-------------------- | | | | | | | | | |-------------------- | | | | | | | | | |-------------------- | | | | | | | | | |-------------------- | | | | | | | | | |--------------------

/*** Метод реализует логику игры: выстрел и передача хода.*/private static void playGame(String player1Name, String player2Name, char[][] playerField1, char[][] playerField2) {        // "карты" выстрелов - создаём двумерные массивы, которые содержат все выстрелы  // удачные (#) и неудачные (*)  char[][] playerBattleField1 = new char[FILED_LENGTH][FILED_LENGTH];        char[][] playerBattleField2 = new char[FILED_LENGTH][FILED_LENGTH];  // вспомогательные переменные, которым будут присваиваться значения текущего игрока -   // игрока, чья очередm делать выстрел. Сначала играет первый игрок, прошу прошения  // за тавтологию        String currentPlayerName = player1Name;        char[][] currentPlayerField = playerField2;        char[][] currentPlayerBattleField = playerBattleField1;  // внутри цикла происходит смена очередности игроков, выстрел, его обработка.  // код внутри цикла выполняется до тех пор, пока "живы" оба игрока - пока у двух игроков  // "частично" цел (ранен) ещё хотя бы один корабль        while (isPlayerAlive(playerField1) && isPlayerAlive(playerField2)) {          // принимаем от пользователя координаты выстрела            System.out.println(currentPlayerName + ", please, input x coord of shot");            int xShot = scanner.nextInt();            System.out.println(currentPlayerName + ", please, input y coord of shot");            int yShot = scanner.nextInt();          // обрабатываем выстрел и получаем возвращаемое значение метода handleShot            int shotResult = handleShot(currentPlayerBattleField, currentPlayerField, xShot, yShot);            // если выстрел неудачный, и не один корабль не повреждён, то очередь переходит к следующему игроку          if (shotResult == 0) {                currentPlayerName = player2Name;              currentPlayerField = playerField1;              currentPlayerBattleField = playerBattleField2;            }        }    }/**    * Метод обрабатывает выстрел. Если выстрел удачный, то есть снаряд достиг цели -    * в клетку записывается значение '#' (отображается к в массиве игрока, так и в массиве соперника),    * а также на экран выводится сообщение 'Good shot!'. В этом случае метод возвращает значение 1.    * В случае неудачного выстрела - в массив battleField записывается значение '0' в элемент [y][x], и    * и возвращается значение 0.    * Возвращаемые значения нам нужны для того, чтобы в методе, внутри которого вызывается метод handleShot,    * мы могли понимать, успешно или неуспешно прошёл выстрел. На основе этого мы принимаем решение, * переходит ход к другому игроку или нет.    */    private static int handleShot(char[][] battleField, char[][] field, int x, int y) {        if ('1'.equals(field[y][x])) {            field[y][x] = '#';            battleField[y][x] = '#';            System.out.println("Good shot!");            return 1;        }        battleField[y][x] = '*';        System.out.println("Bad shot!");        return 0;    }/***Метод определяет, не проиграл ли еще игрок. Если у игрока остался хотя бы    * один "раненный" корабль, тогда пользователь продолжает игру.    * То есть, если на карте у игрока остался хотя бы один символ '1', которым мы отмечали    * корабли, то игра продолжается - возвращается значение true. Иначе false.*/    private static boolean isPlayerAlive(char[][] field) {        for (char[] cells : field) {            for (char cell : cells) {                if ('1' == cell) {                    return true;                }            }        }        return false;    }

int[][] arr = {{1, 2}, {7, 4}, {8, 3, 5, 9}, {1}}System.out.println(arr[0][1]); // ?System.out.println(arr[1][0]); // ?

/*** Метод реализует логику игры: выстрел и передача хода.*/private static void playGame(String player1Name, String player2Name, char[][] playerField1, char[][] playerField2) {// "карты" выстрелов - создаём двумерные массивы, которые содержат все выстрелы    // удачные (#) и неудачные (*)    char[][] playerBattleField1 = new char[FILED_LENGTH][FILED_LENGTH];    char[][] playerBattleField2 = new char[FILED_LENGTH][FILED_LENGTH];    // вспомогательные переменные, которым будут присваиваться значения текущего игрока -     // игрока, чья очередm делать выстрел. Сначала играет первый игрок, прошу прошения    // за тавтологию    String currentPlayerName = player1Name;    char[][] currentPlayerField = playerField2;    char[][] currentPlayerBattleField = playerBattleField1;    // внутри цикла происходит смена очередности игроков, выстрел, его обработка.    // код внутри цикла выполняется до тех пор, пока "живы" оба игрока - пока у двух игроков    // "частично" цел (ранен) ещё хотя бы один корабль    while (isPlayerAlive(playerField1) &amp;&amp; isPlayerAlive(playerField2)) {      // перед каждым выстрелом выводим в консоль отображение всех выстрелов игрока      printField(currentPlayerBattleField);        // принимаем от пользователя координаты выстрела        System.out.println(currentPlayerName + ", please, input x coord of shot");        int xShot = scanner.nextInt();        System.out.println(currentPlayerName + ", please, input y coord of shot");        int yShot = scanner.nextInt();        // обрабатываем выстрел и получаем возвращаемое значение метода handleShot        int shotResult = handleShot(currentPlayerBattleField, currentPlayerField, xShot, yShot);        // если выстрел неудачный, и не один корабль не повреждён, то очередь переходит к следующему игроку          if (shotResult == 0) {            currentPlayerName = player2Name;              currentPlayerField = playerField1;              currentPlayerBattleField = playerBattleField2;        }    }  System.out.println(currentPlayerName + " is winner!");}

private static int validateCoordForShip(char[][] field, int x, int y, int position, int shipType) {        // если пользователь хочет расположить корабль горизонтально  if (position == 1) {            for (int i = 0; i < shipType - 1; i++) {if ('1' == field[y][x + i]                                || '1' == field[y - 1][x + i]                                || '1' == field[y + 1][x + i]                                || '1' == field[y][x + i + 1]                                || '1' == field[y][x + i - 1]|| (x + i) > 9) {                    return -1;                }            }        } else if (position == 2) {          // если пользователь хочет расположить корабль вертикально            for (int i = 0; i < shipType - 1; i++) {                if ('1' == field[y][x + i]                        || '1' == field[y - 1][x + i]                        || '1' == field[y + 1][x + i]                        || '1' == field[y][x + i + 1]                        || '1' == field[y][x + i - 1]|| (y + i) > 9) {                    return -1;                }            }        }        return 0;    }

private static void fillPlayerField(char[][] playerField) {        for (int i = 4; i >= 1; i--) {            // растановка кораблей            for (int k = i; k <= 5 - i; k++) {                System.out.println("Расставляем " + i + "-палубный корабль. Осталось расставить: " + (q + 1));              // иницализируем переменную начальным значением              int validationResult = 1;            while (validationResult != 0) {              System.out.println("Input x coord: ");            x = scanner.nextInt();            System.out.println("Input y coord: ");            y = scanner.nextInt();            System.out.println("1 - horizontal; 2 - vertical ?");            position = scanner.nextInt();                  // если координата не прошла валидацию (проверку), то метод возвращает отрицательное// значение, конечно, оно не равно нулю, поэтому пользователю придётся ввести координаты                  // ещё раз                  validationResult = validateCoordForShip(playerField, x, y, position, i);                }            // если корабль располагаем горизонтально              if (position == 1) {                // заполняем '1' столько клеток по горизонтали, сколько палуб у корабля                for (int q = 0; q < i; q++) {                    playerField[y][x + q] = '1';                }            }                        // если корабль располагаем вертикально            if (position == 2) {                  // заполняем столько клеток по вертикали, сколько палуб у корабля                for (int m = 0; m < i; m++) {                    playerField[y + m][x] = '1';                }            }              // печатаем в консоли поле игрока, на котором будет видно, где игрок уже поставил корабли              // о реализации метода - см. ниже            printField(playerField);        }    }}

Выражение	Эффект
`.students[]`	перебиратьмассив `students`
\|	вывод каждого`student` для следующего фильтра
`.name`	выборка атрибута`name`из объекта`student`

Выражение	Эффект
`.students[]`	перебирать массив`students`
\|	вывод каждого`student` для следующего фильтра
`select(.subjects[] \| contains("science"))`	выберите студента, если его массив`subjects` содержит элемент со строкой наука

Выражение	Эффект
`.timeline.events \| sort_by(.duration) \| reverse`	отсортируйтемассив `timeline.events` по свойству `duration` и реверсируйте результат, чтобы он был отсортирован в порядке убывания
`[]`	перебирать результирующий массив
`select(.startupStep.name \| contains("instantiate"))`	выберите элемент объекта только в том случае, еслисвойство`startupStep` элемента`name` содержит текст instantiate
`{beanName: .startupStep.tags[0].value, duration: .duration}`	создать новый объект JSON со свойствами `beanName` и `duration`

	Русский
	English

Java

Какие задачи решает эта сборка?

Собственно создание сборки

Первая задача

Файловая структура

Пожалуй, начнем с архитектуры

Сервис для логов

Теперь подключим биржу

Перейдем к базе данных

Кому будет интересно?

Блокирующий и неблокирующий код

Разгоняемся сами

А это вообще легально?

Разрыв шаблона. Thread Pool & Reactor

Конфигурируем реактор!

Thread Pool

Распределение задач по рельсам

Платформенные обновления

Любимые проекты пользователей

Годовая подписка

Простые шаги

Sealed-классы и интерфейсы

Необходимость ограниченных иерархий

Определение защищенных иерархий с помощью sealed-классов

Конфигурация IntelliJ IDEA

Возвращаемся к обработке подтипов Plant в классе Gardener

Пакеты и модули

Правила для базовых классов и наследников классов

Sealed-интерфейсы

Записи (records)

Локальные интерфейсы и перечисления

Сопоставление с образцом (pattern matching) для instanceof

Текстовые блоки

Превью

Резюме

SAW-клиент Python

Базовая спецификация вsaw-client

Верификация кода сиспользованием HMAC

Планы

Семантика записей (records)

Прозрачность и ограничения

Математика

Следствия

Преимущества записей

Деструктурирующие паттерны

Блок with

Сериализация

Бойлерплейт код

Недостатки записей

Преимущества Lombok @Data/@Value

Преимущества data-классов Kotlin

Рефлексия

Хиты

Бонус

Вводные

Про Redis Cluster

Про костыли с Redis Cluster и testcontainers

Выводы

Пример кода

Зачем использовать Actuator для анализа и изучения приложения?

Общий обзор Spring Boot Actuator

Шаг 1. Добавьте Actuator зависимость

Шаг 2. Включите и откройте конечные точки

Шаг 3. Защитите и настройте конечные точки

Краткое введение вjq

Изучение приложения Spring Boot

Использование конечной точки отображения

Использование конечной точкиbeans

Использование конечной точкиstartup

Использование конечной точкиenv

Использование конечной точкиscheduledtasks

Использование конечной точкиcaches

Использование конечной точкиhealth

Использование конечной точкиmetrics

Заключение

Что такое кросс-браузерное тестирование?

Преимущества кросс-браузерного тестирования

Время

Тестовое покрытие

Как осуществить кросс-браузерное тестирование в Selenium?