Слияние кода завершено, страница обновится автоматически
Перевод текста на русский язык:
С радостью приглашаем присоединиться к открытому техническому QQ-чату для общения: 613025121.
Понимание принципа удалённого вызова процедур (RPC) через Spring, RabbitMQ и Hessian.
Проще говоря, RPC означает, что вызов удалённых сервисов и вызов локальных сервисов одинаково прозрачен и незаметен. Те, кто использовал Dubbo и Motan, наверняка знакомы с этим ощущением. В процессе реализации удалённого вызова необходимо решить две проблемы:
Если у вас есть собственная схема сериализации, вам также нужно определить структуру тела сообщения для передачи, но это не рассматривается здесь.
Во-первых, при инициализации потребителя и производителя в контейнере Spring, соответствующие очереди будут созданы на RabbitMQ в соответствии с конфигурацией, и потребитель будет следить за соответствующими очередями.
Конфигурация клиента:
<!-- RabbitMQ连接池 -->
<task:executor id="amqpConnectionTaskExecutor" pool-size="5"/>
<!-- RabbitMQ连接器 -->
<rabbit:connection-factory id="connectionFactory" executor="amqpConnectionTaskExecutor" host="127.0.0.1" port="5672" username="admin" password="admin"
virtual-host="/kl"/>
<bean id="myService" class="com.kl.client.MQClientProxyFactoryBean">
<property name="connectionFactory" ref="connectionFactory"/>
<property name="serviceInterface" value="com.kl.api.Service"/>
</bean>
Конфигурация сервера:
<!-- RabbitMQ连接池 -->
<task:executor id="amqpConnectionTaskExecutor" pool-size="5"/>
<!-- RabbitMQ连接器 -->
<rabbit:connection-factory id="connectionFactory" executor="amqpConnectionTaskExecutor" host="127.0.0.1" port="5672" username="admin" password="admin"
virtual-host="/kl"/>
<bean id="ServiceImpl" class="com.kl.apiImpl.ServiceImpl"/>
<bean id="MyServiceEndpoint" class="com.kl.server.MQServerEndpoint">
<constructor-arg index="0" ref="ServiceImpl"/>
<property name="connectionFactory" ref="connectionFactory"/>
</bean>
Тестовый код и примеры
/**
* 暴力测试
* @param args
*/
public static void main(String[] args) {
GenericXmlApplicationContext context = new GenericXmlApplicationContext(
"classpath:/applicationContext-client.xml");
Service service = (Service) context.getBean("myService");
new ClientTest().exec(service);
}
public void exec(Service service){
ExecutorService executorService= Executors.newFixedThreadPool(30);
for(int i=0;i<=30;i++){
executorService.submit(new Task(service));
}
}
private class Task implements Callable {
private Service service;
public Task(Service service){
this.service=service;
}
@Override
public Object call() throws Exception {
for(int i=0;i<=100000;i++){
System.out.println("servicEcho当前线程："+Thread.currentThread().getName()+"| 线程任务数"+i+"| 输出："+service.echo("Hello AMQP!"));
System.out.println("serviceStudent当前线程："+Thread.currentThread().getName()+"| 线程任务数"+i+"| 输出："+service.getStudent(null).getName());
}
return null;
}
}
Примеры тестов
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Комментарии ( 0 )