Resolve the issue of failing to retrieve attachments in dubbo 2.7.6 and 2.7.7

instrumentation/apache-dubbo-2.7/library-autoconfigure/build.gradle.kts

@@ -13,10 +13,29 @@ dependencies {
   testLibrary("org.apache.dubbo:dubbo-config-api:2.7.0")
 }
 
+val latestDepTest = findProperty("testLatestDeps") as Boolean
+
+testing {
+  suites {
+    val testLatestDepDubbo by registering(JvmTestSuite::class) {
+      dependencies {
+        implementation("org.apache.dubbo:dubbo:+")
+        implementation(project(":instrumentation:apache-dubbo-2.7:library-autoconfigure"))
+      }
+    }
+  }
+}
+
 tasks.withType<Test>().configureEach {
   jvmArgs("-XX:+IgnoreUnrecognizedVMOptions")
   // to suppress non-fatal errors on jdk17
   jvmArgs("--add-opens=java.base/java.math=ALL-UNNAMED")
   // required on jdk17
   jvmArgs("--add-opens=java.base/java.lang=ALL-UNNAMED")
 }
+
+if (!(findProperty("testLatestDeps") as Boolean)) {
+  tasks.check {
+    dependsOn(testing.suites)
+  }
+}

instrumentation/apache-dubbo-2.7/library-autoconfigure/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/DubboHeadersGetter.java

@@ -6,14 +6,31 @@
 package io.opentelemetry.instrumentation.apachedubbo.v2_7;
 
 import io.opentelemetry.context.propagation.TextMapGetter;
+import java.lang.reflect.Method;
+import java.util.Collections;
+import java.util.Map;
+import org.apache.dubbo.rpc.RpcInvocation;
 
 enum DubboHeadersGetter implements TextMapGetter<DubboRequest> {
   INSTANCE;
 
   @Override
-  @SuppressWarnings("deprecation") // deprecation for dubbo 3.2.15
+  @SuppressWarnings("unchecked") // unchecked for 2.7.6, 2.7.7
   public Iterable<String> keys(DubboRequest request) {
-    return request.invocation().getAttachments().keySet();
+    RpcInvocation invocation = request.invocation();
+    try {
+      // In 2.7.6, 2.7.7, the StringToObjectMap implementation does not correctly retrieve the
+      // keySet. Therefore, it's advisable to always call getObjectAttachments when it is available.
+      Method getObjectAttachmentsMethod = invocation.getClass().getMethod("getObjectAttachments");
+      if (getObjectAttachmentsMethod != null) {
+        return ((Map<String, Object>) getObjectAttachmentsMethod.invoke(invocation)).keySet();
+      } else {
+        return invocation.getAttachments().keySet();
+      }
+    } catch (Exception e) {
+      // ignore
+    }
+    return Collections.emptyList();
   }
 
   @Override

instrumentation/apache-dubbo-2.7/library-autoconfigure/src/testLatestDepDubbo/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/DubboHeadersGetterTest.java

@@ -0,0 +1,42 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.instrumentation.apachedubbo.v2_7;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.mockito.Mockito.when;
+
+import java.net.InetSocketAddress;
+import java.util.Iterator;
+import org.apache.dubbo.common.URL;
+import org.apache.dubbo.rpc.RpcContext;
+import org.apache.dubbo.rpc.RpcInvocation;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+@ExtendWith(MockitoExtension.class)
+class DubboHeadersGetterTest {
+
+  @Mock RpcContext context;
+
+  @Test
+  @SuppressWarnings("deprecation") // deprecation for RpcInvocation()
+  void testKeys() {
+    when(context.getUrl()).thenReturn(new URL("http", "localhost", 1));
+    when(context.getRemoteAddress()).thenReturn(new InetSocketAddress(1));
+    when(context.getLocalAddress()).thenReturn(new InetSocketAddress(1));
+
+    RpcInvocation invocation = new RpcInvocation();
+    invocation.setAttachment("key", "value");
+    DubboRequest request = DubboRequest.create(invocation, context);
+
+    Iterator<String> iterator = DubboHeadersGetter.INSTANCE.keys(request).iterator();
+    assertThat(iterator.hasNext()).isTrue();
+    assertThat(iterator.next()).isEqualTo("key");
+    assertThat(iterator.hasNext()).isFalse();
+  }
+}