Architecture des Programmes CICS : Transaction Processing

				
					* Configuration TCPIPSERVICE avec TLS
DEFINE TCPIPSERVICE(WEBSVC) GROUP(WEBGROUP)
    PORT(8443)
    PROTOCOL(HTTP)
    SSL(YES)
    CERTIFICATE('CICSCERT')
    CIPHERS('TLS_AES_256_GCM_SHA384:TLS_CHACHA20_POLY1305_SHA256')
    AUTHENTICATE(REQUIRED)
    CLIENTCERTIFICATE(REQUIRED)

* Programme CICS exposé en REST/JSON
IDENTIFICATION DIVISION.  
PROGRAM-ID. RESTAPI.

PROCEDURE DIVISION.
MAIN-PROCESSING.
    * Parsing de la requête HTTP JSON
    EXEC CICS WEB READ
        HTTPHEADER(WS-HTTP-HEADERS)
        NAMELENGTH(WS-NAME-LEN)
        CHARACTERSET(1208)      * UTF-8
    END-EXEC
    
    * Validation token JWT  
    PERFORM VALIDATE-JWT-TOKEN
    
    * Traitement métier
    IF JWT-VALID
        PERFORM PROCESS-REST-REQUEST
        PERFORM BUILD-JSON-RESPONSE
    ELSE
        MOVE 401 TO HTTP-STATUS-CODE
        MOVE '{"error":"Unauthorized"}' TO JSON-RESPONSE
    END-IF
    
    * Envoi réponse sécurisée
    EXEC CICS WEB SEND
        FROM(JSON-RESPONSE)
        MEDIATYPE('application/json')
        STATUSCODE(HTTP-STATUS-CODE)
        STATUSTEXT('OK')
    END-EXEC
				
			

				
					* Publishing d'événements vers Kafka via MQ Bridge
WORKING-STORAGE SECTION.
01  EVENT-MESSAGE.
    05  EVENT-HEADER.
        10  EVENT-TYPE          PIC X(20) VALUE 'CUSTOMER_UPDATE'.
        10  EVENT-TIMESTAMP     PIC X(26).
        10  EVENT-SOURCE        PIC X(8) VALUE 'CICSPROD'.
        10  EVENT-VERSION       PIC X(5) VALUE '1.0.0'.
    05  EVENT-PAYLOAD.
        10  CUSTOMER-ID         PIC X(10).
        10  OPERATION-TYPE      PIC X(10).
        10  PREVIOUS-STATE      PIC X(100).
        10  NEW-STATE           PIC X(100).

PROCEDURE DIVISION.
PUBLISH-CUSTOMER-EVENT.
    * Construction événement CloudEvents compliant
    MOVE FUNCTION CURRENT-DATE TO EVENT-TIMESTAMP
    MOVE 'UPDATE' TO OPERATION-TYPE
    MOVE OLD-CUSTOMER-DATA TO PREVIOUS-STATE
    MOVE NEW-CUSTOMER-DATA TO NEW-STATE
    
    * Publication via MQ vers Kafka Connect
    EXEC CICS PUT QUEUE('KAFKA.EVENTS.CUSTOMER')
        FROM(EVENT-MESSAGE)
        LENGTH(LENGTH OF EVENT-MESSAGE)
        CORRELID(CUSTOMER-ID)
    END-EXEC

* Configuration MQ-Kafka Bridge (côté MQ)
DEFINE CHANNEL(KAFKA.BRIDGE) CHLTYPE(SVRCONN)
    TRPTYPE(TCP)
    MCAUSER('KAFKAUSER')
    DESCR('Channel for Kafka Connect')

DEFINE QLOCAL(KAFKA.EVENTS.CUSTOMER) 
    DESCR('Customer events for Kafka streaming')
    MAXDEPTH(100000)
    MSGDLVSQ(PRIORITY)
    DEFPRTY(5)
    
* Exemple consumer Kafka (côté applicatif moderne)
// Configuration Kafka Consumer pour événements CICS
Properties props = new Properties();
props.put("bootstrap.servers", "kafka-cluster:9092");
props.put("group.id", "cics-event-processor");
props.put("key.deserializer", StringDeserializer.class);
props.put("value.deserializer", "CICSEventDeserializer");

KafkaConsumer consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("cics-customer-events"));

while (true) {
    ConsumerRecords records = consumer.poll(100);
    for (ConsumerRecord record : records) {
        processCICSEvent(record.value()); // Traitement événement
    }
}