小编ray*_*man的帖子

我试图使项目列表动态,所以我可以在运行时添加它,但我不知道.CharSeqence不是动态的,也不知道如何使用适配器选项,我怎么能改变我的代码是动态的？

private void alertDialogLoadFile() {

    AlertDialog.Builder alert = new AlertDialog.Builder(this);
    alert.setTitle("Choose:");  
    CharSequence[] items = { "moshe", "yosi", "ee" };
    alert.setSingleChoiceItems(m_items , -1, new DialogInterface.OnClickListener() {

        public void onClick(DialogInterface dialog, int item){
            /* User clicked on a radio button do some stuff */
        }
    });

    alert.setPositiveButton("Yes", new DialogInterface.OnClickListener() {

        public void onClick(DialogInterface dialog, int id) {
    }
    });

    alert.setNegativeButton("No", new DialogInterface.OnClickListener() {

        public void onClick(DialogInterface dialog, int id) {
            dialog.cancel();
        }
    });


    AlertDialog ad = alert.create();
    ad.show();

}

我正在使用JMS Queue和MDB来收听它.我有一个重试机制,所以当抛出异常时,将发生对事务的回滚并且操作将重新执行/

我想实现Message_retry_number,每次执行"onMessage"时,我都可以编写当前的执行重试次数.我听说我可以通过消息对象的Header检索它,但是在属性或网络中找不到任何东西.

有谁有任何线索？

谢谢,雷.

我的设置是使用netflix库的spring boot cloud我设法让Turbine从一个服务聚合Hystrix指标.但是,当我添加更多服务时,我无法看到它们.

这是我的设置(也将其上传到github: Project On Github

服务1:

FlightIntegrationService:

@SpringBootApplication
@EnableCircuitBreaker
@EnableDiscoveryClient
@ComponentScan("com.bootnetflix")
public class FlightIntegrationApplication {
..
}

application.yaml

server:
  port: 0

eureka:
  instance:
    leaseRenewalIntervalInSeconds: 10
    metadataMap:
      instanceId: ${vcap.application.instance_id:${spring.application.name}:${spring.application.instance_id:${random.value}}}
  client:
    registryFetchIntervalSeconds: 5

bootstrap.yaml

spring:
  application:
    name: flight-integration-service

服务2:

优惠券服务:

@SpringBootApplication
@EnableCircuitBreaker
@EnableDiscoveryClient
@ComponentScan("com.bootnetflix")
public class CouponServiceApp {
..
}

application yaml:

server:
  port: 0

eureka:
  instance:
    leaseRenewalIntervalInSeconds: 10
    metadataMap:
      instanceId: ${vcap.application.instance_id:${spring.application.name}:${spring.application.instance_id:${random.value}}}
  client:
    registryFetchIntervalSeconds: 5

Eureka应用服务:

@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication  {



Hystrix dashboard service:

    @SpringBootApplication
    @EnableHystrixDashboard
    @Controller
    public class …

我们有7个微服务通过eventbus进行通信.我们有一个实时的交易顺序:

服务1-> service2-> service3(依此类推.)直到交易被视为已完成

我们必须确保所有交易都发生.

当然,我们可以在任何时候出现失败.因此,我们正在考虑将机制设备重播为"半成品"交易.

这变得棘手.我们考虑的两种方式:

1. 拥有另一个服务(主管服务),它将在我们的实时序列中记录每个部分,并且在交易未完成时(时间超时)足够聪明,以了解我们如何从左点继续

   缺点:一个中央服务上有很多"智能"逻辑

2. 每个服务都有重试机制,而每个服务都有自己的服务,并重播它自己直到成功或被解雇

   缺点:每个服务上有很多重试重复代码

你有什么专家的想法？

谢谢

在我的应用程序中,我有一个非活动对象,它的角色是经理类.很多时候我需要将"源活动"传递给方法作为该管理器类的参数,以便对该活动进行一些操作.

例如,让我们假设我们有MyActivity,它必须做一些吐司.所以我有这个名为MyManager的经理类,我有这个方法

raiseToast(Activity sourceActivity) {

  Toast.makeText(sourceActivity, demo, Toast.LENGTH_LONG).show();
}

从Myactivity类我们以这种方式调用该方法:

MyManager manager=new MyManager();
manager.raiseToast(MyActivity.this);

它工作正常.

我在这里问的是,这是将Activity作为参数传递给非活动对象的正确方法吗？我在真实设备(而不是模拟器)上有内存泄漏,我想知道这是否也会导致任何原因？

谢谢Idan.

我正在使用 vertx3

我需要使用 redis 来设置和获取值。（Redis 将来可能会更改为其他内容）

我正在为我的实现寻找最佳实践设计。

我正在研究 vertx 集群，我需要通过 eventbus 检索消息提取消息并插入到 Redis 中。

另一方面，我可以通过网络获取请求，也可以提取消息并将它们插入到 redis 中

两种选择：

1. 我是否应该有一个“redis-verticle”来通过总线获取消息并写入它们。

2. 我应该创建一个“侦听器垂直”来保存 DAO，它将保存将写入它们的 RedisRepo 对象。

   我也将能够处理网络调用并持有这个 DAO 对象

如果我在 spring-app 上，我会创建一个包含 RedisRepo 的 DAO 并将其注入我的服务层，但在这里我们得到了 eventbus，所以我不确定。

（顺便说一下，redis 数据源我被改成了别的东西，所以我得考虑通用包装器）

1. 

public class RedisRepoVerticle extends AbstractVerticle {

...
 public void start() {
 client = new RedisClient("localhost", 6379);
                 connection = client.connect();
...

vertx.eventBus().consumer("redis-operation", (handler) -> {
            {
                JsonObject msg = new JsonObject(handler.body().toString());
               //write straight to Redis 

            }
        });

}






2. 

     public class RedisMessageListener extends AbstractVerticle …

我使用的是jboss5.1.x,EJB3.0,JPA3.

我试图从视图中"选择"查询,该视图通过dblink连接到另一个数据库.

源数据库是Oracle 9,目标dabatase是Oracle 8.

我收到此错误:

15:27:06,625 WARN [JDBCExceptionReporter] SQL Error: 24777, SQLState: 99999

15:27:06,625 ERROR [JDBCExceptionReporter] ORA-24777: use of non-migratable database link not allowed

在我明白在使用XA时无法使用dblink之后,我找到了解决此错误的方法.所以我设法解决了通过更改dblink脚本来创建共享数据库链接,如下所示:

 CREATE SHARED DATABASE LINK CONNECT TO IDENTIFIED BY AUTHENTICATED BY IDENTIFIED BY USING 

在这个测试环境中一切正常.

现在我已将我的应用程序移动到生产环境,其中源数据库是Oracle 11,而目标仍然是Oracle 8.

我这次使用的技巧没有工作,我找不到解决方案.这是我得到的新例外:

    Caused by: org.hibernate.exception.GenericJDBCException: could not execute query
    at ....Caused by: java.sql.SQLException: ORA-01012: not logged on
    ORA-02063: preceding line from TO_VANTIVE …

我想向我说清楚.

我读到了AOP概念,我明白这是分享跨领域服务的好方法.(记录,安全,交易......)

但我想说/询问一下这个想法及其实施情况.

我读到有一些方法,比如AspectJ,JBOSS AOP,以便将AOP同化到我的业务逻辑中.

但很久以前不是这里的吗？

比方说,我想在我的组件(Java bean,EJB',无论如何......)之间共享一个日志记录或安全实现.

为什么我不能让Singleton bean确保它只有一个实例,只要任何组件需要它的日志/安全服务,它就会查找并使用它的服务.

为什么我需要了解并拥有所有那些"大"实现,例如aspectj或jboss AOP？我在这里想念什么？

在尝试使用事件总线通过测试类测试Vert.x Verticle时,我遇到了"阻塞错误".这里是垂直和测试类:

EventBusReceiverVerticle:

public class EventBusReceiverVerticle extends AbstractVerticle {

    public EventBusReceiverVerticle(String name) {
        this.name = name;
    }

    public void start() {

              vertx.eventBus().consumer("geo-service", (Message<JsonObject> handler) -> {
            {
                try {
                    System.out.println("sleep 10 seconds");
                    Thread.sleep(10000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }           
            }
        });
    }
}

测试类:

@RunWith(VertxUnitRunner.class)
public class MyFirstVerticleTest {
    Vertx vertx;
    EventBus eb;
    private static final Logger logger = LoggerFactory.getLogger(MyFirstVerticleTest.class);


    @Before
    public void setUp(TestContext context) {
        logger.info("@Before");
        vertx = Vertx.vertx();
        eb = vertx.eventBus();

        Async async = context.async(); …

我们想要手动提交kafka偏移量来控制数据丢失事件。但是我们可能会延迟手动提交，因为我们只想在持久化到数据源之后才执行此操作

我想了解减慢提交偏移量如何影响卡夫卡的主题/并行/分区（如果有的话）